import {J,handleResponse,ResponseData,newResponseData} from "../../utils";
import { AppMaster } from "@onebro/appmaster";
import { Response } from "supertest";
import {getWorker} from "@onebro/oba-dev-workers";
import path from "path";
import { sleep } from "@onebro/oba-common";

export const sybilReaderApiTests = () => J.desc("Sybil Reader",() => {
  let job:any,o:any,jobdata:any;
  let m:AppMaster,app:any,data:ResponseData,user:any;
  const filename = path.join(__dirname,"/../../../file-uploads/test-dl.jpg");
  const worker = getWorker("read");
  const watch = async (id:string) => {
    do{
      o = await worker.get(id);
      const {progress,state,logs} = o;
      const status = logs[logs.length - 1];
      console.log({id,progress,state,status});
      await sleep(5000);}
    while(!["completed","failed"].includes(o.state));
    return o;
  };
  /*
  it("init w/o errors",async () => {
    const o = await require("../../utils/init");
    m = o.master;
    app = o.app;
    data = newResponseData();},9999);
  it("GET / 200 - Api Home OK [Get Csrf Token]",async (done) => {
    await app
    .get("/")
    .set("Origin","https://oba-dev-apps.com")
    .set("oba-CLIENT-ID","fin-map-api")
    .set("oba-CLIENT-KEY","1873487748")
    .set("XSRF-TOKEN",data.csrfToken)
    .set("Cookie",data.cookieArr)
    .set("Accept","application/json")
    .expect("Content-Type",/json/)
    .expect(200)
    .expect((res:Response) => {
      data = handleResponse(data,res);
      done();});},99999);
  it("POST /auth/set 200 - Set OK [Returning User]",async (done) => {
    await app
    .post("/auth/set")
    .send({username:"jackswift"})
    .set("Origin","https://oba-dev-apps.com")
    .set("oba-CLIENT-ID","fin-map-api")
    .set("oba-CLIENT-KEY","1873487748")
    .set("XSRF-TOKEN",data.csrfToken)
    .set("Cookie",data.cookieArr)
    .set("Accept","application/json")
    .expect("Content-Type",/json/)
    .expect(200)
    .expect((res:Response) => {
      data = handleResponse(data,res);
      user = res.body;
      done();});},99999);
  it("POST /auth/login 200 - Login OK [Returning User]",async (done) => {
    await app
    .post("/auth/login")
    .send({pin:"9999"})
    .set("Origin","https://oba-dev-apps.com")
    .set("oba-CLIENT-ID","fin-map-api")
    .set("oba-CLIENT-KEY","1873487748")
    .set("XSRF-TOKEN",data.csrfToken)
    .set("Cookie",data.cookieArr)
    .set("Accept","application/json")
    .set("Authorization","Bearer "+user.token)
    .expect("Content-Type",/json/)
    .expect(200)
    .expect((res:Response) => {
      data = handleResponse(data,res);
      user = res.body;
      //console.log(user);
      done();});},99999);
  it("POST /profiles - Create Profile [200 OK]",async (done) => {
    await app
    .post("/profiles")
    .send({settings:{lang:"en"}})
    .set("Origin","https://oba-dev-apps.com")
    .set("oba-CLIENT-ID","fin-map-api")
    .set("oba-CLIENT-KEY","1873487748")
    .set("Authorization","Bearer "+user.token)
    .set("XSRF-TOKEN",data.csrfToken)
    .set("Cookie",data.cookieArr)
    .set("Accept","application/json")
    .expect("Content-Type",/json/)
    .expect(201)
    .expect((res:Response) => {
      data = handleResponse(data,res);
      user.profile = res.body;
      done();});},99999);
  it("POST /uploads/readImg - upload and read img file (PNG)",async (done) => {
    const filePath = `C:/Users/OneBrother/Desktop/test-file.png`;
    //const exists = await fs.exists(filePath);
    //if(!exists) throw new Error("file does not exist");
    await app
    .post("/uploads/readImg")
    .set("Origin","https://oba-dev-apps.com")
    .set("oba-CLIENT-ID","fin-map-api")
    .set("oba-CLIENT-KEY","1873487748")
    .set("Authorization","Bearer "+user.token)
    .set("XSRF-TOKEN",data.csrfToken)
    .set("Cookie",data.cookieArr)
    .set("Accept","application/json")
    .expect("Content-Type",/json/)
    .attach("testdoc",filePath)
    .expect(201)
    .expect((res:Response) => {
      data = handleResponse(data,res);
      user.file = res.body;
      console.log(user.file);
      //J.true(user.file.uploadDate);
      //J.is(user.file.filename);
      done();});},99999);
  */
  it("clear all jobs",async (done) => {await worker.clear();done();},1E9);
  it("add reader job",async (done) => {job = await worker.add({filename});done();},1E9);
  it("watch reader job",async (done) => {jobdata = await watch(job.id);done();},1E9);
  it("print data",async (done) => {console.log(jobdata);done();},1E9);
});