1 | const {Asset} = require("../bundle.js");
|
2 | const rp = require("request-promise");
|
3 |
|
4 | async function contribute(id){
|
5 | let a = await Asset.getById("PROD", id);
|
6 | let files = await a.getFiles();
|
7 | let x = files.arr[9]
|
8 |
|
9 | log(await x.getContent());
|
10 | let labels;
|
11 |
|
12 | labels = files.findByName("ClassifiedAmazonLabelsEvents_Txt");
|
13 | if(labels){
|
14 | log("Contributing amz label " + a.name);
|
15 | let content = JSON.parse(await labels.getContent());
|
16 | let res = await rp.post({
|
17 | method: "POST",
|
18 | uri: `http://localhost:8080/addData`,
|
19 | body: content,
|
20 | qs: {
|
21 | movieId: a.id,
|
22 | provider: "amazon",
|
23 | type: "label",
|
24 | movieName: a.name,
|
25 | },
|
26 | resolveWithFullResponse: true,
|
27 | json: true,
|
28 | });
|
29 | labels = null;
|
30 | }
|
31 |
|
32 | labels = files.findByName("ClassifiedGoogleLabelsEvents_Txt");
|
33 | if(labels){
|
34 | log("Contributing google label " + a.name);
|
35 | let content = JSON.parse(await labels.getContent());
|
36 | log(content);
|
37 | let res = await rp.post({
|
38 | method: "POST",
|
39 | uri: `http://localhost:8080/addData`,
|
40 | body: content,
|
41 | qs: {
|
42 | movieId: a.id,
|
43 | provider: "google",
|
44 | type: "label",
|
45 | movieName: a.name,
|
46 | },
|
47 | resolveWithFullResponse: true,
|
48 | json: true,
|
49 | });
|
50 | labels = null;
|
51 | }
|
52 | };
|
53 |
|
54 | contribute(479466);
|
55 |
|