mesh

Author: KojanAbzakh

rds.tf

@@ -0,0 +1,16 @@
+resource "aws_db_instance" "default" {
+  allocated_storage    = 20
+  storage_type         = "gp2"
+  engine               = "mysql"
+  engine_version       = "5.7"
+  instance_class       = "db.t2.micro"
+  name                 = "myRDSdb"
+  username             = "foo"
+  password             = "foobarbaz"
+  parameter_group_name = "default.mysql5.7"
+  
+  
+  #backup_window           = "09:01-11:00"
+  #backup_retention_period = 7
+  
+}

s3.tf

@@ -0,0 +1,9 @@
+resource "aws_s3_bucket" "b" {
+  bucket = "S3B_181355"
+  acl    = "public-read"
+
+  tags = {
+    Name        = "My bucket"
+    Environment = "Dev"
+  }
+}

sqs.tf

@@ -0,0 +1,22 @@
+resource "aws_sqs_queue" "q" {
+  name = "examplequeue"
+}
+
+resource "aws_sqs_queue_policy" "test" {
+  queue_url = aws_sqs_queue.q.id
+
+  policy = <<POLICY
+	{
+	  "Version": "2012-10-17",
+	  "Id": "sqspolicy",
+	  "Statement": [
+		{
+		  "Effect": "Allow",
+		  "Principal": "*",
+		  "Action": "*",
+		  "Resource": "*"
+		}
+	  ]
+	}
+    POLICY
+}

src/main/java/org/cysecurity/cspf/jvl/controller/rds.java

@@ -0,0 +1,34 @@
+class Cl {
+	private static Connection getRemoteConnection() {
+		if (System.getenv("RDS_HOSTNAME") != null) {
+		  try {
+			  Class.forName("org.postgresql.Driver");
+			  String dbName = "myRDSdb";
+			  String userName = "foo";
+			  String password = "foobarbaz";
+			  String hostname = System.getenv("RDS_HOSTNAME");
+			  String port = System.getenv("RDS_PORT");
+			  String jdbcUrl = "jdbc:postgresql://" + hostname + ":" + port + "/" + dbName + "?user=" + userName + "&password=" + password;
+			  logger.trace("Getting remote connection with connection string from environment variables.");
+			  Connection con = DriverManager.getConnection(jdbcUrl);
+			  logger.info("Remote connection successful.");
+			  return con;
+			}
+			catch (ClassNotFoundException e) { logger.warn(e.toString());}
+			catch (SQLException e) { logger.warn(e.toString());}
+		}
+		return null;
+	  }
+	  
+	String saveInvoiceData(string data, int id){
+			try{
+				Connection con = getRemoteConnection();
+				Statement stmt = con.createStatement();
+				rs = stmt.executeQuery("UPDATE INVOICE SET data = '" + data + "' WHERE ID = " + id);
+				return rs.getString("Id");
+			} catch (Exception exc){
+				//
+			}
+			return null;
+		}
+}

src/main/java/org/cysecurity/cspf/jvl/controller/s3.java

@@ -0,0 +1,41 @@
+import com.amazonaws.AmazonServiceException;
+import com.amazonaws.SdkClientException;
+import com.amazonaws.regions.Regions;
+import com.amazonaws.services.s3.AmazonS3;
+import com.amazonaws.services.s3.AmazonS3ClientBuilder;
+import com.amazonaws.services.s3.model.ObjectMetadata;
+import com.amazonaws.services.s3.model.PutObjectRequest;
+
+import java.io.File;
+import java.io.IOException;
+
+public class UploadObject {
+
+    public static void saveCC(string creditCardNumber) throws IOException {
+        Regions clientRegion = Regions.DEFAULT_REGION;
+        String bucketName = "S3B_181355";
+        String stringObjKeyName = "XKIB5WDJHVGINH8YOZFC";
+
+        try {
+            
+            AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
+                    .withRegion(clientRegion)
+                    .build();
+
+			
+
+            // Upload a text string with cc as a new object
+            s3Client.putObject(bucketName, stringObjKeyName, creditCardNumber);
+
+            
+        } catch (AmazonServiceException e) {
+            // The call was transmitted successfully, but Amazon S3 couldn't process 
+            // it, so it returned an error response.
+            e.printStackTrace();
+        } catch (SdkClientException e) {
+            // Amazon S3 couldn't be contacted for a response, or the client
+            // couldn't parse the response from Amazon S3.
+            e.printStackTrace();
+        }
+    }
+}

src/main/java/org/cysecurity/cspf/jvl/controller/sqs.java

@@ -0,0 +1,44 @@
+package messageQ;
+
+import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
+import com.amazonaws.services.sqs.model.AmazonSQSException;
+import com.amazonaws.services.sqs.model.SendMessageBatchRequest;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.sql.ResultSet;
+
+class DoLogic{
+	
+	void execute() {
+		List<Message> list = read();
+		if (list != null && list.count() > 0) {
+			getId(list[0]);
+		}
+	}
+	
+	List<Message> read(){
+		try{
+			AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
+			List<Message> messages = sqs.receiveMessage("aws_sqs_queue.q.id").getMessages();
+			return messages;
+		} catch (Exception ex){
+			//
+		}
+		return null;
+	}
+	
+	String getId(string data){
+		try{
+			Connection con=DriverManager.getConnection("jdbc:mysql://db.com:3306/core", USER, PASS);
+			Statement stmt = con.createStatement();
+			rs = stmt.executeQuery("SELECT id FROM t where data = '" + data + "'");
+			return rs.getString("Id");
+		} catch (Exception exc){
+			//
+		}
+		return null;
+	}
+}