Avevo un problema simile da risolvere e come soluzione temporanea Ho inizializzato l'app con serviceAccount di amministrazione di Firebase. Quindi ho ascoltato le modifiche della raccolta di Firebase sul mio server e sul nuovo valore ricevuto inserito\aggiornato i valori in PostgreSQL.
Inizializza l'app come amministratore e ascolta le modifiche su Firebase:
admin.initializeApp({
credential: admin.credential.cert(serviceAccount),
databaseURL: 'https://yourfirebaseproject.firebaseio.com',
});
const db = admin.database();
db.ref('User').on('value', async (snapshot) => {
insertOrUpdate(User, 'users', snapshot.val());
});
Inserisci\aggiorna i dati in PostgreSQL:
const insertOrUpdate = (model, tableName, data) => {
const firstData = data[0] ? data[0] : data;
return model.knex().raw(
knex(tableName).insert(data).toQuery() + ' ON CONFLICT ("id") DO UPDATE SET ' +
Object.keys(firstData).map((field) => `${field}=EXCLUDED.${field}`).join(', ')
);
};