Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ----- myData
- -------eqewrwrepere (this one is a device token)
- ---------Lta+sde-fer (this one is a firebase id)
- firstvalue : "a"
- secondvalue : "b"
- ----------Qrgd+ad-qdda (this one is second firebase id)
- firstvalue : "c"
- secondvalue : "d"
- -------eqwerSAsdqe (this one is another device token)
- ---------Lta+sde-fer (this one is a firebase id)
- firstvalue : "x"
- secondvalue : "y"
- ----------Qrgd+ad-qdda (this one is second firebase id)
- firstvalue : "z"
- secondvalue : "t"
- 'use strict';
- const functions = require('firebase-functions');
- const admin = require('firebase-admin');
- admin.initializeApp(functions.config().firebase);
- var request = require('request');
- var fs = require('fs');
- //var fs = require("fs");
- // Get a reference to the Cloud Vision API component
- const Vision = require('@google-cloud/vision');
- const vision = new Vision.ImageAnnotatorClient();
- // Imports the Google Cloud client library
- //const {Storage} = require('@google-cloud/storage');
- var fs = require("fs");
- var os = require("os");
- var databaseArray = [];
- exports.hourly_job = functions.pubsub
- .topic('fiyat-takip-et')
- .onPublish((event) => {
- console.log("Hourly Job");
- var db = admin.database();
- var ref = db.ref("myData")
- ref.once("value").then(function(allData) {
- allData.forEach(function(deviceToken) {
- deviceToken.forEach(function(firebaseIDs) {
- var deviceTokenVar = deviceToken.key;
- var firebaseIDVar = firebaseIDs.key;
- var firstvalue = firebaseIDs.child("firstvalue").val();
- var secondvalue = firebaseIDs.child("secondvalue").val();
- var items = [deviceTokenVar, firebaseIDVar, firstvalue, secondvalue];
- databaseArray.push([...items]);
- });
- });
- return databaseArray;
- }).then(function (databasem) {
- var i;
- for (i = 0; i < databaseArray.length; i++) {
- var databaseArrayDeviceToken = databaseArray[i][0];
- console.log("DeviceToken: " + databaseArrayDeviceToken);
- var databaseArrayFirebaseID = databaseArray[i][1];
- console.log("FirebaseID: " + databaseArrayFirebaseID);
- var databaseArrayfirstvalue = databaseArray[i][2];
- console.log("firstval: " + databaseArrayfirstvalue);
- var databaseArraysecondval = databaseArray[i][3];
- console.log("GuncelFiyat: " + databaseArraysecondval);
- var url = "http://api.blabla" + databaseArrayfirstvalue;
- /////////////here make a request, pause loop, process returned image, but how //////////////////////
- request.get({url: url, encoding: 'binary'}, function (error, httpResponse, body) {
- if (!error && httpResponse.statusCode == 200) {
- fs.writeFileSync('/tmp/processed.jpg', body, 'binary')
- console.log("file written");
- })
- }
- });
- return true;
- });
Add Comment
Please, Sign In to add comment