Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Base64;

import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.stereotype.Service;

import com.cloudconvert.client.CloudConvertClient;
import com.cloudconvert.client.setttings.StringSettingsProvider;
import com.cloudconvert.dto.request.Base64ImportRequest;
import com.cloudconvert.dto.request.ConvertFilesTaskRequest;
import com.cloudconvert.dto.request.UrlExportRequest;
import com.cloudconvert.dto.response.JobResponse;
import com.cloudconvert.dto.response.TaskResponse;
import com.google.common.collect.ImmutableMap;
import com.smartdukaan.cron.Application;
import com.twocaptcha.TwoCaptcha;
import com.twocaptcha.captcha.Normal;

@Service
public class CaptchaService {

        private static final Logger LOGGER = LogManager.getLogger(Application.class);

        public String getCaptchaCode(String filePath) throws Exception {
                File inputFile = new File("/tmp/captcha.avif");
                File jpgFile = this.getCloudConvertJpgImg(inputFile);
                LOGGER.info("After conver called");
                System.out.println("Trying 2captcha");
                TwoCaptcha solver = new TwoCaptcha("dbb4583561b064de1c0a48b8232c72e8");

                Normal captcha = new Normal(jpgFile.getAbsolutePath());

                System.out.println("Before captcha");
                solver.solve(captcha);
                return captcha.getCode();
        }

        private File getCloudConvertJpgImg(File avifImg) throws Exception {
                final CloudConvertClient cloudConvertClient = new CloudConvertClient(new StringSettingsProvider(
                                "eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiJ9.eyJhdWQiOiIxIiwianRpIjoiNTFkZjQ2OWM4N2YxZmQ1YzQ3MGMxNTk0ZjlmZTM2MDU4NDVhOWJkYTU5ZWFmOWMxNjViM2NmYzllOWE3NjY5MjEyZmM2ODkyNTQ3NjNlOWYiLCJpYXQiOjE2MzMzMjYyMDYuNzA1NTgyLCJuYmYiOjE2MzMzMjYyMDYuNzA1NTg1LCJleHAiOjQ3ODg5OTk4MDYuNjczMTk4LCJzdWIiOiI1Mzc3MDQ1NiIsInNjb3BlcyI6WyJ1c2VyLnJlYWQiLCJ1c2VyLndyaXRlIiwidGFzay5yZWFkIiwidGFzay53cml0ZSIsIndlYmhvb2sucmVhZCIsIndlYmhvb2sud3JpdGUiLCJwcmVzZXQucmVhZCIsInByZXNldC53cml0ZSJdfQ.ebPY4qqvOmjWUl075bcl9Oum40mCOpnDj3uSC22ynriMvWs3nGQBZ_jD8uQPoCgW0Q3rAVJp9IBBAfvPC0IVxNLOK10A2w4VnlFH7sSSdG9nocbUlyfYFjOaU_XC0KVwqi2j1tNsQHeGKhCadjtHWm8L6oh7Npvn2ClkxlSX4NB7sX0TsodvHIcfoTyLvZ1LA71Bbpx0Sn8oVXYQsMl6SMbQisEw50vhlxkbJ71PXI2G6LtI3WYIwVtDpOLYbAwEpIzA_jpbVvCRJdrPMSlLidWa_Ci4S1ugUt1zUoXIkNAxUfmhbcEszwaGHXbOMUaoF8cE8RRtZF-bPCFQu5jLRDxBCtGfcbr_jiSEHMg0P4UTq1lwTX6bSqe3dIM_2f0jepWE4hpGVHPCmZC00xqmobdJ8PMRlHTD_CdnwvECxvpcm5bO4gKQ42BlZe52qivp1xxqoRZFR948A1g6EY7ADXb6xXXrM-uxaskLfGxvCO_l1U-Lcz31LsNgShiTL9VYdX8kBxJY0pW9FF7Uek_4XhuV9CUUxmz6t1qgTP5pfNzjTNADHB67x_pIgje5DLhyEUsiHK9MCmXTbYbBByTUG0l2-43UGJ7XlLppqMcOeJwQ-DO-O59NlHpkOEVJdY0ZhbvLppIit0v3j_JsUPfYYeZqEtE0tphVIhb9O0PgNUc",
                                "IemxwFEudKWn89TATevY3Ip492gmmgB1", false));

                byte[] fileContent = FileUtils.readFileToByteArray(avifImg);
                String encodedString = Base64.getEncoder().encodeToString(fileContent);

                final JobResponse createJobResponse = cloudConvertClient.jobs()
                                .create(ImmutableMap.of("import-my-file",
                                                new Base64ImportRequest().setFile(encodedString).setFilename(avifImg.getName()),
                                                "convert-my-file",
                                                new ConvertFilesTaskRequest().setInput("import-my-file").setInputFormat("avif").setOutputFormat(
                                                                "jpg"),
                                                "export-my-file", new UrlExportRequest().setInput("convert-my-file")))
                                .getBody();

                LOGGER.info("Create jobResponse - {}", createJobResponse);

                // Get a job id
                final String jobId = createJobResponse.getId();

                // Wait for a job completion
                final JobResponse waitJobResponse = cloudConvertClient.jobs().wait(jobId).getBody();

                final String exportUrlTaskId = waitJobResponse.getTasks().stream()
                                .filter(taskResponse -> taskResponse.getName().equals("export-my-file")).findFirst().get().getId();

                // Wait for an export/url task to be finished
                final TaskResponse waitUrlExportTaskResponse = cloudConvertClient.tasks().wait(exportUrlTaskId).getBody();

                // Get url and filename of export/url task
                final String exportUrl = waitUrlExportTaskResponse.getResult().getFiles().get(0).get("url");
                final String filename = waitUrlExportTaskResponse.getResult().getFiles().get(0).get("filename");

                LOGGER.info(exportUrl, filename);

                // Get file as input stream using url of export/url task
                final InputStream inputStream = cloudConvertClient.files().download(exportUrl).getBody();

                // Save to local file
                File localFile = new File("/tmp/converted.jpg");
                OutputStream outputStream = new FileOutputStream(localFile);
                IOUtils.copy(inputStream, outputStream);

                return localFile;
        }
}