test bw

Dockerfile

@@ -12,6 +12,7 @@ FROM openjdk:11-jdk-slim
 COPY --from=build /target/demo-0.0.1-SNAPSHOT.jar demo.jar
 COPY --from=build /user.properties user.properties
 COPY --from=build /urls.txt urls.txt
+COPY --from=build /ggsheet.txt ggsheet.txt
 COPY --from=build /mydb.db mydb.db
 # ENV PORT=8080 
 EXPOSE 7860

ggsheet.txt

@@ -0,0 +1 @@
+https://script.google.com/macros/s/AKfycbwGvcAkhVHiFG-eULvGuenVDssyQGdMjUB_7ijxXuyc2UMRxk8z57KHaYpScseNOWsCtw/callback?nocache_id=5

pom.xml

@@ -45,25 +45,25 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-data-jpa</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.postgresql</groupId>
-            <artifactId>postgresql</artifactId>
-            <scope>runtime</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.xerial</groupId>
-            <artifactId>sqlite-jdbc</artifactId>
-            <version>3.7.2</version>
-        </dependency>
-        <dependency>
-            <groupId>com.h2database</groupId>
-            <artifactId>h2</artifactId>
-            <scope>compile</scope>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.boot</groupId>-->
+<!--            <artifactId>spring-boot-starter-data-jpa</artifactId>-->
+<!--        </dependency>-->
+<!--        <dependency>-->
+<!--            <groupId>org.postgresql</groupId>-->
+<!--            <artifactId>postgresql</artifactId>-->
+<!--            <scope>runtime</scope>-->
+<!--        </dependency>-->
+<!--        <dependency>-->
+<!--            <groupId>org.xerial</groupId>-->
+<!--            <artifactId>sqlite-jdbc</artifactId>-->
+<!--            <version>3.7.2</version>-->
+<!--        </dependency>-->
+<!--        <dependency>-->
+<!--            <groupId>com.h2database</groupId>-->
+<!--            <artifactId>h2</artifactId>-->
+<!--            <scope>compile</scope>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>

src/main/java/com/example/demo/DemoApplication.java

@@ -1,7 +1,10 @@
 package com.example.demo;
 
 import com.example.demo.entity.User_test;
-import com.example.demo.repository.UserRepository;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.message.BasicNameValuePair;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -50,6 +53,9 @@ import org.apache.http.impl.client.DefaultHttpClient;
 import org.apache.http.util.EntityUtils;
 import tqtk.Utils.Doc_file_kieu_txt;
 
+import javax.servlet.http.HttpServletResponse;
+import java.io.InputStream;
+
 @SpringBootApplication
 @RestController
 public class DemoApplication {
@@ -64,13 +70,100 @@ public class DemoApplication {
         context = SpringApplication.run(DemoApplication.class, args);
     }
 
+    public static int index = 0;
+
+    @GetMapping("getFile")
+    public void getFile(HttpServletResponse response) throws IOException {
+
+        List<String> lists = Doc_file_kieu_txt.readFile("urls.txt");
+
+        index = ++index % lists.size();
+
+        response.setHeader("Pragma", "no-cache");
+        response.setHeader("Cache-Control", "no-cache");
+
+        HttpClient httpClient = new DefaultHttpClient();
+        try {
+            HttpPost get = new HttpPost(lists.get(index));
+
+            get.setHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/85.0.4183.121 Safari/537.36");
+
+            get.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9");
+            get.setHeader("Sec-Fetch-Dest", "empty");
+            get.setHeader("Sec-Fetch-Mode", "cors");
+            get.setHeader("Sec-Fetch-Site", "same-origin");
+            get.setHeader("X-Same-Domain", "1");
+
+            CloseableHttpResponse Cresponse = (CloseableHttpResponse) httpClient.execute(get);
+            int s = Cresponse.getStatusLine().getStatusCode();
+            Cresponse.getEntity().getContent().transferTo(response.getOutputStream());
+        } catch (IOException ex) {
+            ex.getMessage();
+        }
+
+    }
+
+    public static int countOk = 0 ;
+    @GetMapping("count_ok")
+    public String getOK() throws IOException {
+        return Integer.toString(countOk);
+    }
+
+    @GetMapping("start_spam2")
+    public String startSpam2() throws IOException {
+        new Thread() {
+            @Override
+            public void run() {
+                while (true) {
+                    HttpClient httpClient = new DefaultHttpClient();
+                    try {
+                        HttpGet get = new HttpGet("https://lisatthu35-java-test-bw.hf.space/getFile");
+
+                        get.setHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/85.0.4183.121 Safari/537.36");
+
+                        get.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9");
+                        get.setHeader("Sec-Fetch-Dest", "empty");
+                        get.setHeader("Sec-Fetch-Mode", "cors");
+                        get.setHeader("Sec-Fetch-Site", "same-origin");
+                        get.setHeader("X-Same-Domain", "1");
+
+                        CloseableHttpResponse Cresponse = (CloseableHttpResponse) httpClient.execute(get);
+                        int s = Cresponse.getStatusLine().getStatusCode();
+                        if(s==200){
+							InputStream inputStream = Cresponse.getEntity().getContent();
+							long contentLength = Cresponse.getEntity().getContentLength();
+							byte[] buffer = new byte[4096];
+							int bytesRead;
+							long totalBytesRead = 0;
+							while ((bytesRead = inputStream.read(buffer)) != -1) {
+								totalBytesRead += bytesRead;
+								if (totalBytesRead == contentLength) {
+									break;
+								}
+							}
+                            countOk++;
+                        }
+                    } catch (IOException ex) {
+                        ex.getMessage();
+                    }
+                    try {
+                        Thread.sleep(4000);
+                    } catch (InterruptedException ex) {
+                        Logger.getLogger(DemoApplication.class.getName()).log(Level.SEVERE, null, ex);
+                    }
+                }
+            }
+        }.start();
+        return "ok";
+    }
+
     @GetMapping("start_spam")
     public String startSpam() throws IOException {
         LocalTime now = LocalTime.now();
         new Thread() {
             @Override
             public void run() {
-                List<String> lists = Doc_file_kieu_txt.readFile("urls.txt");
+                List<String> lists = Doc_file_kieu_txt.readFile("ggsheet.txt");
                 int i = 0;
                 while (true) {
                     i = ++i % lists.size();
@@ -298,10 +391,15 @@ public class DemoApplication {
             get.setHeader("Sec-Fetch-Mode", "cors");
             get.setHeader("Sec-Fetch-Site", "same-origin");
             get.setHeader("X-Same-Domain", "1");
+            List<NameValuePair> pa = new ArrayList<>();
+            pa.add(new BasicNameValuePair("request", "[\"call1\",\"[]\",null,[0],null,null,1,0]"));
+
+            HttpEntity httpEntity = new UrlEncodedFormEntity(pa, "UTF-8");
+            get.setEntity(httpEntity);
 
             CloseableHttpResponse Cresponse = (CloseableHttpResponse) httpClient.execute(get);
             int s = Cresponse.getStatusLine().getStatusCode();
-            Util.writeFile(LocalTime.now().format(formatter) + " status " + s, "/log.txt");
+//            Util.writeFile(LocalTime.now().format(formatter) + " status " + s, "/log.txt");
             return;
         } catch (IOException ex) {
             ex.getMessage();

src/main/java/com/example/demo/Test.java

@@ -1,7 +1,6 @@
 package com.example.demo;
 
 import com.example.demo.entity.User_test;
-import com.example.demo.repository.UserRepository;
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import java.io.BufferedInputStream;

src/main/java/com/example/demo/entity/User.java

@@ -1,44 +0,0 @@
-package com.example.demo.entity;
-
-import javax.persistence.*;
-import java.io.Serializable;
-
-@Entity
-@Table(name = "users")
-public class User implements Serializable {
-
-    @Id
-    @SequenceGenerator(name = "sequenceGenerator", sequenceName = "sequence_name_user", allocationSize = 1, initialValue = 1)
-    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "sequenceGenerator")
-    private Long id;
-
-    @Column(name = "first_name", length = 50)
-    private String firstName;
-
-    @Column(name = "last_name", length = 50)
-    private String lastName;
-
-    public Long getId() {
-        return id;
-    }
-
-    public void setId(Long id) {
-        this.id = id;
-    }
-
-    public String getFirstName() {
-        return firstName;
-    }
-
-    public void setFirstName(String firstName) {
-        this.firstName = firstName;
-    }
-
-    public String getLastName() {
-        return lastName;
-    }
-
-    public void setLastName(String lastName) {
-        this.lastName = lastName;
-    }
-}

src/main/java/com/example/demo/repository/UserRepository.java

@@ -1,9 +0,0 @@
-package com.example.demo.repository;
-
-import com.example.demo.entity.User;
-import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.stereotype.Repository;
-
-@Repository
-public interface UserRepository extends JpaRepository<User, Long> {
-}

src/main/java/com/sqlite/config/DBConfig.java

@@ -6,7 +6,7 @@ import org.springframework.boot.jdbc.DataSourceBuilder;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
-@Configuration
+//@Configuration
 public class DBConfig {
     @Bean
 	public DataSource dataSource() {

src/main/java/com/sqlite/config/DBInitializeConfig.java

@@ -10,7 +10,7 @@ import javax.sql.DataSource;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
 
-@Configuration
+//@Configuration
 public class DBInitializeConfig {
 
     @Autowired

src/main/java/com/sqlite/config/SQLiteDialect.java

@@ -1,155 +0,0 @@
-package com.sqlite.config;
-
-import java.sql.Types;
-
-import org.hibernate.dialect.Dialect;
-import org.hibernate.dialect.function.SQLFunctionTemplate;
-import org.hibernate.dialect.function.StandardSQLFunction;
-import org.hibernate.dialect.function.VarArgsSQLFunction;
-import org.hibernate.type.StringType;
-
-public class SQLiteDialect extends Dialect {
-    public SQLiteDialect() {
-        registerColumnType(Types.BIT, "integer");
-        registerColumnType(Types.TINYINT, "tinyint");
-        registerColumnType(Types.SMALLINT, "smallint");
-        registerColumnType(Types.INTEGER, "integer");
-        registerColumnType(Types.BIGINT, "bigint");
-        registerColumnType(Types.FLOAT, "float");
-        registerColumnType(Types.REAL, "real");
-        registerColumnType(Types.DOUBLE, "double");
-        registerColumnType(Types.NUMERIC, "numeric");
-        registerColumnType(Types.DECIMAL, "decimal");
-        registerColumnType(Types.CHAR, "char");
-        registerColumnType(Types.VARCHAR, "varchar");
-        registerColumnType(Types.LONGVARCHAR, "longvarchar");
-        registerColumnType(Types.DATE, "date");
-        registerColumnType(Types.TIME, "time");
-        registerColumnType(Types.TIMESTAMP, "timestamp");
-        registerColumnType(Types.BINARY, "blob");
-        registerColumnType(Types.VARBINARY, "blob");
-        registerColumnType(Types.LONGVARBINARY, "blob");
-        // registerColumnType(Types.NULL, "null");
-        registerColumnType(Types.BLOB, "blob");
-        registerColumnType(Types.CLOB, "clob");
-        registerColumnType(Types.BOOLEAN, "integer");
-
-        registerFunction( "concat", new VarArgsSQLFunction(StringType.INSTANCE, "", "||", "") );
-        registerFunction( "mod", new SQLFunctionTemplate( StringType.INSTANCE, "?1 % ?2" ) );
-        registerFunction( "substr", new StandardSQLFunction("substr", StringType.INSTANCE) );
-        registerFunction( "substring", new StandardSQLFunction( "substr", StringType.INSTANCE) );
-    }
-
-    public boolean supportsIdentityColumns() {
-        return true;
-    }
-
-  /*
-  public boolean supportsInsertSelectIdentity() {
-    return true; // As specify in NHibernate dialect
-  }
-  */
-
-    public boolean hasDataTypeInIdentityColumn() {
-        return false; // As specify in NHibernate dialect
-    }
-
-  /*
-  public String appendIdentitySelectToInsert(String insertString) {
-    return new StringBuffer(insertString.length()+30). // As specify in NHibernate dialect
-      append(insertString).
-      append("; ").append(getIdentitySelectString()).
-      toString();
-  }
-  */
-
-    public String getIdentityColumnString() {
-        // return "integer primary key autoincrement";
-        return "integer";
-    }
-
-    public String getIdentitySelectString() {
-        return "select last_insert_rowid()";
-    }
-
-    public boolean supportsLimit() {
-        return true;
-    }
-
-    protected String getLimitString(String query, boolean hasOffset) {
-        return new StringBuffer(query.length()+20).
-                append(query).
-                append(hasOffset ? " limit ? offset ?" : " limit ?").
-                toString();
-    }
-
-    public boolean supportsTemporaryTables() {
-        return true;
-    }
-
-    public String getCreateTemporaryTableString() {
-        return "create temporary table if not exists";
-    }
-
-    public boolean dropTemporaryTableAfterUse() {
-        return false;
-    }
-
-    public boolean supportsCurrentTimestampSelection() {
-        return true;
-    }
-
-    public boolean isCurrentTimestampSelectStringCallable() {
-        return false;
-    }
-
-    public String getCurrentTimestampSelectString() {
-        return "select current_timestamp";
-    }
-
-    public boolean supportsUnionAll() {
-        return true;
-    }
-
-    public boolean hasAlterTable() {
-        return false; // As specify in NHibernate dialect
-    }
-
-    public boolean dropConstraints() {
-        return false;
-    }
-
-    public String getAddColumnString() {
-        return "add column";
-    }
-
-    public String getForUpdateString() {
-        return "";
-    }
-
-    public boolean supportsOuterJoinForUpdate() {
-        return false;
-    }
-
-    public String getDropForeignKeyString() {
-        throw new UnsupportedOperationException("No drop foreign key syntax supported by SQLiteDialect");
-    }
-
-    public String getAddForeignKeyConstraintString(String constraintName,
-                                                   String[] foreignKey, String referencedTable, String[] primaryKey,
-                                                   boolean referencesPrimaryKey) {
-        throw new UnsupportedOperationException("No add foreign key syntax supported by SQLiteDialect");
-    }
-
-    public String getAddPrimaryKeyConstraintString(String constraintName) {
-        throw new UnsupportedOperationException("No add primary key syntax supported by SQLiteDialect");
-    }
-
-    public boolean supportsIfExistsBeforeTableName() {
-        return true;
-    }
-
-    public boolean supportsCascadeDelete() {
-        return false;
-    }
-}

src/main/resources/application.properties

@@ -1,9 +1,9 @@
 server.tomcat.accesslog.enabled=true
 
-spring.profiles.active=dev
-spring.jpa.database-platform=com.sqlite.config.SQLiteDialect
+#spring.profiles.active=dev
+#spring.jpa.database-platform=com.sqlite.config.SQLiteDialect
 #spring.jpa.hibernate.ddl-auto=create-drop
-spring.jpa.hibernate.ddl-auto=create
-spring.jpa.show-sql=true
-spring.jpa.hibernate.naming-strategy=org.hibernate.cfg.EJB3NamingStrategy
+#spring.jpa.hibernate.ddl-auto=create
+#spring.jpa.show-sql=true
+#spring.jpa.hibernate.naming-strategy=org.hibernate.cfg.EJB3NamingStrategy
 server.port=7860