UNPKG

2.74 kBJavaScriptView Raw
1const {Asset} = require("../bundle.js");
2const rt = require("../bundle.js");
3const rp = require("request-promise");
4const fs = require("fs");
5process.env["NODE_TLS_REJECT_UNAUTHORIZED"] = 0;
6
7//const fwurl = "http://localhost:3000/addData";
8const fwurl = "https://fenway.dev.discovery.com/addData";
9async 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 //fs.writeFileSync("/Users/jschmidt/fenway-2/test/samples/amazon_label.json", JSON.stringify(content, null, 4));
24 //process.exit(1);
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
78async 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
88main();
89//contribute(462286);