1 | const {Asset} = require("../bundle.js");
|
2 | const rt = require("../bundle.js");
|
3 | const rp = require("request-promise");
|
4 | const fs = require("fs");
|
5 | process.env["NODE_TLS_REJECT_UNAUTHORIZED"] = 0;
|
6 |
|
7 |
|
8 | const fwurl = "https://fenway.dev.discovery.com/addData";
|
9 | async function contribute(id){
|
10 | write("starting " + id + "...")
|
11 | let a = await Asset.getById("PROD", id);
|
12 | let files = await a.getFiles();
|
13 | let md = await a.getMetadata();
|
14 |
|
15 | let labels;
|
16 |
|
17 | labels = files.findByName("ClassifiedAmazonLabelsEvents_Txt");
|
18 | if(labels){
|
19 | write("Downloading....");
|
20 | let content = JSON.parse(await labels.getContent());
|
21 | write("Contributing amz label " + a.name + "...");
|
22 |
|
23 |
|
24 |
|
25 | let res = await rp({
|
26 | method: "POST",
|
27 | uri: fwurl,
|
28 | body: content,
|
29 | qs: {
|
30 | movieId: a.id,
|
31 | provider: "amazon",
|
32 | type: "label",
|
33 | movieName: a.name,
|
34 | fileLabel: "ClassifiedAmazonLabelsEvents_Txt",
|
35 | fileCreatedDate: Date.now(),
|
36 | proxyFramerate: md.Workflow.FWInfo.fps,
|
37 | proxyStartTimecode: md.Workflow.FWInfo.start,
|
38 |
|
39 | },
|
40 | resolveWithFullResponse: true,
|
41 | json: true,
|
42 | });
|
43 |
|
44 | log(res.body);
|
45 | labels = null;
|
46 | }
|
47 |
|
48 | labels = files.findByName("ClassifiedGoogleLabelsEvents_Txt");
|
49 | if(labels && false){
|
50 | write("Downloading....");
|
51 | let content = JSON.parse(await labels.getContent());
|
52 | log("Contributing google label " + a.name);
|
53 | let res = await rp({
|
54 | method: "POST",
|
55 | uri: fwurl,
|
56 | body: content,
|
57 | qs: {
|
58 | movieId: a.id,
|
59 | provider: "google",
|
60 | type: "label",
|
61 | movieName: a.name,
|
62 | fileLabel: "ClassifiedGoogleLabelsEvents_Txt",
|
63 | fileCreatedDate: Date.now(),
|
64 | proxyFramerate: md.Workflow.FWInfo.fps,
|
65 | proxyStartTimecode: md.Workflow.FWInfo.start,
|
66 | },
|
67 | resolveWithFullResponse: true,
|
68 | json: true,
|
69 | });
|
70 |
|
71 | log(res.body);
|
72 | labels = null;
|
73 | }
|
74 | };
|
75 |
|
76 |
|
77 |
|
78 | async function main(){
|
79 | let files = fs.readFileSync("mainout.txt", "utf-8")
|
80 | .trim().split("\n")
|
81 | .map(x => x.slice(3))
|
82 | .slice(6265);
|
83 |
|
84 | await rt.lib.keepalive(async (...a) => contribute(...a).catch(e=>process.stdout.write(e)), files, {chunksize: 2});
|
85 | }
|
86 |
|
87 |
|
88 | main();
|
89 |
|