guillermo/floriday
guillermo
/
floriday
1
1
Fork 0
Code Issues Pull Requests Releases Activity

refs #4823 Changed API_URL to new version

This commit is contained in:
Guillermo Bonet 2023-04-25 08:09:52 +02:00
parent 090c050729
commit 355912fc57
3 changed files with 7 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -32,7 +32,7 @@ npm i
CLIENT_ID = xxxxxxxxxx CLIENT_ID = xxxxxxxxxx
CLIENT_SECRET = xxxxxxxxxx CLIENT_SECRET = xxxxxxxxxx
API_KEY = xxxxxxxxxx API_KEY = xxxxxxxxxx
API_URL = https://api.staging.floriday.io/customers-api/2022v2 API_URL = https://api.staging.floriday.io/customers-api-2023v1
API_ENDPOINT = https://idm.staging.floriday.io/oauth2/ausmw6b47z1BnlHkw0h7/v1/token API_ENDPOINT = https://idm.staging.floriday.io/oauth2/ausmw6b47z1BnlHkw0h7/v1/token
#SEQUELIZE CONFIG #SEQUELIZE CONFIG

6
models/supplier/suppliers.js
View File

@ -43,12 +43,6 @@ const suppliers = {
physicalAddress: { physicalAddress: {
type: Sequelize.JSON, type: Sequelize.JSON,
}, },
pythosanitaryNumber: {
type: Sequelize.STRING,
},
organizationType: {
type: Sequelize.STRING,
},
isConnected: { isConnected: {
type: Sequelize.BOOLEAN, type: Sequelize.BOOLEAN,
defaultValue: false, defaultValue: false,

13
utils.js
View File

@ -4,6 +4,7 @@ import { models } from './models/index.js';
import { v4 as uuidv4 } from 'uuid'; import { v4 as uuidv4 } from 'uuid';
import chalk from 'chalk'; import chalk from 'chalk';
import ora from 'ora'; import ora from 'ora';
const env = process.env;
/** /**
* Gets the Access Token from the client config table * Gets the Access Token from the client config table
@ -238,12 +239,12 @@ export async function syncSuppliers(){
let headers = { let headers = {
'Content-Type': 'application/json', 'Content-Type': 'application/json',
'Authorization': `Bearer ${await getCurrentToken()}`, 'Authorization': `Bearer ${await getCurrentToken()}`,
'X-Api-Key': process.env.API_KEY 'X-Api-Key': process.env.API_KEY,
}; };
const response = await fetch(`${env.API_URL}/organizations/current-max-sequence`, { const response = await fetch(`${env.API_URL}/organizations/current-max-sequence`, {
method: 'GET', method: 'GET',
headers headers,
}); });
if (!response.ok) { if (!response.ok) {
@ -255,14 +256,14 @@ export async function syncSuppliers(){
let timeFinish, timeToGoSec, timeToGoMin, timeLeft; let timeFinish, timeToGoSec, timeToGoMin, timeLeft;
for (let curSequenceNumber = 0; curSequenceNumber <= maxSequenceNumber; curSequenceNumber++) { for (let curSequenceNumber = 0; curSequenceNumber <= maxSequenceNumber; curSequenceNumber++) {
let timeStart = new moment(); let timeStart = new moment();
let query = `${env.API_URL}/organizations/sync/${curSequenceNumber}?organizationType=SUPPLIER`; let query = `${env.API_URL}/organizations/sync/${curSequenceNumber}?organizationType=SUPPLIER`;
let response = await fetch(query, { let response = await fetch(query, {
method: 'GET', method: 'GET',
headers headers
}); });
let data = await response.json(); let data = await response.json();
let suppliers = data.results; let suppliers = data.results;
for (let supplier of suppliers) { for (let supplier of suppliers) {
curSequenceNumber = supplier.sequenceNumber; curSequenceNumber = supplier.sequenceNumber;
@ -283,10 +284,8 @@ export async function syncSuppliers(){
endDate: supplier.endDate, endDate: supplier.endDate,
mailingAddress: supplier.mailingAddress, mailingAddress: supplier.mailingAddress,
physicalAddress: supplier.physicalAddress, physicalAddress: supplier.physicalAddress,
pythosanitaryNumber: supplier.pythosanitaryNumber,
organizationType: supplier.organizationType
}); });
} };
await syncSequence(curSequenceNumber, 'suppliers', maxSequenceNumber); await syncSequence(curSequenceNumber, 'suppliers', maxSequenceNumber);
timeFinish = new moment(); timeFinish = new moment();
timeToGoSec = (timeFinish.diff(timeStart, 'seconds') * (maxSequenceNumber - curSequenceNumber) / 1000) timeToGoSec = (timeFinish.diff(timeStart, 'seconds') * (maxSequenceNumber - curSequenceNumber) / 1000)