From 5a6860194a485e4e2dc81c084bb57468685fa4df Mon Sep 17 00:00:00 2001
From: sandyx <sandyx.code@proton.me>
Date: Thu, 4 Jun 2026 21:02:46 -0500
Subject: [PATCH] initial commit

---
 .pipesocket.rb.swp | Bin 0 -> 12288 bytes
 backshot_client.rb |  68 +++++++++++++++++++
 cli.rb             |   4 ++
 listen.rb          |   4 ++
 pipesocket.rb      | 162 +++++++++++++++++++++++++++++++++++++++++++++
 server.rb          |  16 +++++
 srv.rb             |   5 ++
 test.rb            |   4 ++
 8 files changed, 263 insertions(+)
 create mode 100644 .pipesocket.rb.swp
 create mode 100644 backshot_client.rb
 create mode 100644 cli.rb
 create mode 100644 listen.rb
 create mode 100644 pipesocket.rb
 create mode 100644 server.rb
 create mode 100644 srv.rb
 create mode 100644 test.rb

diff --git a/.pipesocket.rb.swp b/.pipesocket.rb.swp
new file mode 100644
index 0000000000000000000000000000000000000000..f268d9018d9f6d10b568ae3e50ce5ba6153cead5
GIT binary patch
literal 12288
zcmeI2J8T?97{@0d!XpWfBs>HHP40wpCidD+3cx7xVIvSlAi|ge5?On@bH2^(?Ob-|
z?AVS8LLh`hB#MX%s)&jP^N<h-3DM9{hDSjK6%?dFDIf*^Z}xG!XA>TV!f00d?Q6dI
zX68TNH*=P^G4{;kNBD!zIKy!>V|TxC`-yk=-p0nRVNAJ^zjTTUu6!hRYUGIPO-b1v
zc|u4hl%5+7RC_)#9G#ZF7=5bOSQ_mHU7@7c7P@fj#EpT9_R%U}71*2tJ>496VAt%S
zgX3f5s9M>__w1hCoKIWZDqt0`3RnfK0#*U5fK|XMU=`R>3h3@Ob_PAZD(!WgUbhWg
z(?@%;3RnfK0#*U5fK|XMU=^?mSOu&CRspMkRbUG$;QEZcay4V~_<ukB|3CZt|Kd%I
zeFZLn_rZJMJa`!_g9Xq7K9~gefm;CsKitUJ8h9JL1>OX&f#YBb+zGaW3%eNm0GtCS
z!BH>_F70IOd$0!1ftSECcos~8`@tb_5Znv)f{QyC`wW~1CxHOR!7*?I>;v1uH#ac$
z2{;2<;2|&$ZUL9BXY6P26ZjE)3SI{SJPl^RBVa$+33h<X*D>}R_zrvw-T|+I7r-pI
z3+w^A!7tZh%-~D#1^5WO2$sMJFahoXziwyjTkttp182c1Xo6$lIq(>`16;<ueGNVY
zXTd5^pbgBNZo!zeUA7AR&lC`m&p3|kO82Xb&e>5c$=+$%7LnqIc}LAVsv8EnR^gQ)
zmX&AMDsKj%;E~%ATm{RbWDqoy>e`L<++v_xle|Lam68=&Ks)p;mNPH3%FAZV*IADC
zx^qgz3nHEirR>(~T^Z{kzQRvamD9O-H5T52>5XFf%kn@?8(t_?xtkk}-<WoLTJg%f
zlzwArpwl88aKdpkV&S&)w&@KW1y?N*hO#{RR3on?J6(SGFt2Q2vpI!0Gu^<cYJBI9
z`OTE;wP#vVI~}2vJ1=-843rj85Y2NLaT1(YSB&thN$-8p<cW=OVopUF6Xi0$6R3?b
z6zXOrS&KCk4<*x9bW`ttrH2qXicj`tlAwshVy#X=H_Yp<@5i{9u*ip0b-CAaqez5Y
zORnIQH!w=BTY|?z^+KJS<~K!8XfE+fZgYzuQu@Gw{L%CPmKAcXAYgTcEDGZcqCf|3
zh{UM%-K7Jq*U1>w@l_PZ;c6Yvxt@nPkTIX|WT%6#AU7(a;mlE+%nMzmc%~-4t;+AY
zDZ+~wUpppA>d8pE=n-bsjW{*#MxNlZX;gu!TacK;Iuf1^WHihdTY=YtZk`Ahgo0hM
zAq>11LSBLQNus8qK@Bw}e%57Enq6tMk76Bgd=UyQkkYPh_1Bgpc&3r3<beVY#i^)N
zwVc!@>G--dQmvl$<ziIMwm(<_OlM?QL`heMc_ltjF>4G3;Au{0$8?KQvE2UVl9SPZ
z=rCRAw3|UwZmh?X=w49|k``0q`gpl6DH*ve%3ZuSWpOOyT7_DL!jws?+zrXy5*MeC
z{mLn<_E6XK&y-Bo$h<#YW_rqbh@eiAvmf-PN3?7dQex0%D2?YN$tm4gHIkb5lxX(C
z$^STz1|=eyC|-ni*6$fq__rdDDs0q3$q`njuG8NNHjZJcL5GRQehp?`7EZk=#8N`5
zUDt^M$X6&cw^V|eO2=5*do$CtEDQa0E|TCk>2ZbnXe60Z+RSUkWwswh)FSQg+?RPP
zf0CAEyML5Bql<B%)2*F?GhOu7??i)BC;r9!p(KGsbjgQgwllmeZ9gW{@RIVzSpLO)
zqD)FAppZhR0?o&bmt?)|8}+wq@}G<}*`KTY;o=q%U@M5YY@EP8fjz|4j0KSw_I#1f
Z_r%1sG}{b**2UsvFNg)-pTyLD_B)6KQP}_h

literal 0
HcmV?d00001

diff --git a/backshot_client.rb b/backshot_client.rb
new file mode 100644
index 0000000..e6c9901
--- /dev/null
+++ b/backshot_client.rb
@@ -0,0 +1,68 @@
+require 'socket'
+
+def error(msg)
+    puts "error: #{msg}"
+    exit 1
+end
+
+class BackShotClient
+    def initialize(addr, port)
+        @addr = addr
+        @port = port
+        @hello = false
+    end
+
+    def get_resp(sock)
+        msg = sock.gets
+        error("not ok: #{msg}") if msg.chomp != "ok"
+    end
+
+    def hello
+        TCPSocket.open(@addr, @port) { |sock|
+            sock.puts "hello"
+            @hello = true if sock.gets.chomp == "hello"
+        }
+    end
+
+    def send_file_info(path)
+        hello unless @hello
+  
+        TCPSocket.open(@addr, @port) { |sock|
+            sock.puts "file #{path} #{File.size path}"
+            get_resp sock
+        }
+    end
+
+    def send_file(path)
+        self.send_file_info path
+        TCPSocket.open(@addr, @port) { |sock| 
+            sock.write File.read path
+            get_resp sock
+        } 
+    end
+    
+    def send_exec(path)
+        TCPSocket.open(@addr, @port) { |sock|
+            sock.puts "run #{path}"
+            get_resp sock
+        }
+    end
+
+    def send_return(path)
+        TCPSocket.open(@addr, @port) { |sock|
+            sock.puts "return #{path}"
+            File.open(path, "w+") { |file| file.write sock.read }
+            sock.puts "thanks"
+        }
+    end
+end
+
+def send_file_info(path)
+    TCPSocket.open("127.0.0.1")
+end
+
+bsc = BackShotClient.new "127.0.0.1", 8081
+bsc.send_file "test.rb"
+bsc.send_exec "test.rb"
+bsc.send_return "happy.txt"
+
diff --git a/cli.rb b/cli.rb
new file mode 100644
index 0000000..ec7fa09
--- /dev/null
+++ b/cli.rb
@@ -0,0 +1,4 @@
+require './pipesocket'
+
+cli = PipeSocket.new("pipe0", "127.0.0.1", 8080)
+cli.connect
diff --git a/listen.rb b/listen.rb
new file mode 100644
index 0000000..bcf7da9
--- /dev/null
+++ b/listen.rb
@@ -0,0 +1,4 @@
+require './pipesocket.rb'
+
+sp = SocketPipe.new "sockpipe", "127.0.0.1", "8080"
+sp.listen
diff --git a/pipesocket.rb b/pipesocket.rb
new file mode 100644
index 0000000..1aff0f2
--- /dev/null
+++ b/pipesocket.rb
@@ -0,0 +1,162 @@
+require 'socket'
+include Socket::Constants
+
+# A PipeSocket is an object that
+
+def error(msg)
+    puts "PipeSocket: #{msg}"
+    exit 1
+end
+
+class PipeSocket
+    def initialize(name, addr, port)
+        @path = name
+        @port = port
+        @addr = addr
+        if File.exist?(name)
+            error("File #{name} already exists.")
+        end
+    end
+
+    def connect
+        puts "Opening #{@path} for read/write"
+        File.mkfifo(@path)
+        File.open(@path, "r+") { |pipe|
+            loop do
+                socket = Socket.tcp(@addr, @port)
+                msg = pipe.gets
+                socket.puts msg
+                resp = socket.gets
+                unless resp.nil?
+                    puts resp.chomp
+                    break if resp.chomp == "shutdown"
+                end
+                break if msg.chomp == "shutdown"
+                socket.close
+            end
+        }
+        puts "Closing #{@path}"
+        File.delete(@path)
+    end
+end
+
+#not useful?
+class SocketPipe
+    def initialize(name, addr, port)
+        @path, @addr, @port = name, addr, port
+        if File.exist?(name)
+            error("File #{name} already exists.")
+        end
+    end
+
+    def listen
+        puts "Opening #{@path} for reading"
+        File.mkfifo(@path)
+        Socket.tcp_server_loop(@port) { |sock|
+            msg = sock.gets
+            File.open(@path, "r+") { |pipe| pipe.puts msg }
+            sock.close
+            break if msg.chomp == "shutdown"
+        }
+        puts "Closing #{@path}"
+        File.delete(@path)
+    end
+end
+
+# BackShot should be a server listening for
+# a PipeSocket connection, which receives a 
+# ruby file containing an instance of the 
+# BackShot class
+
+class BackShot
+    attr_accessor :send_back
+    attr_accessor :command
+
+    @@inst = 0
+
+    def initialize(addr, port)
+        @name = "backshot#{@@inst}"
+        @@inst += 1
+        @addr = addr
+        @port = port
+
+        @return = nil
+        @execute = nil
+        
+        #a channel to send back the result
+    end
+
+    def BackShot.message(msg)
+        puts "BackShot: #{msg}"
+    end
+    
+    def listen
+        BackShot.message "listening on port #{@port}"
+        loop do
+        #hello
+        Socket.tcp_server_loop(@port) { |sock| 
+            msg = sock.gets
+            if msg.chomp == "hello"
+                sock.puts "hello"
+                break
+            else
+                sock.puts "goodbye"
+            end
+            sock.close
+        }
+
+        def recv_file(filename, expected_size)
+            Socket.tcp_server_loop(@port) { |sock|
+                data = sock.recv(expected_size)
+                File.open(filename, "w+") { |file| file.write data }
+                sock.puts "ok"
+                
+            }
+        end
+
+        #recv files
+        Socket.tcp_server_loop(@port) { |sock|
+            msg = sock.gets
+            if msg.start_with? "file"
+                puts "file info recv"
+                # file name size
+                file, name, size = msg.split(" ")
+                size = size.chomp
+                sock.puts "ok"
+                
+                recv_file(name, size)
+            elsif msg.start_with? "run"
+                puts "run recv"
+                # execute file
+                exec, name = msg.split(" ")
+                @execute = name
+                sock.puts "ok"
+                #sock.close
+            elsif msg.start_with? "return"
+                puts "return recv"
+                ret, name = msg.split(" ")
+                @return = name
+                if @execute == nil
+                    sock.puts "error"
+                   # sock.close
+                    break
+                end
+                `./#{@execute}`
+                sock.write File.read(@return)
+                msg = sock.gets
+                if msg.chomp == "thanks"
+                    @execute = nil
+                    #sock.close
+                    break
+                end
+            else
+                sock.puts "what"
+                #sock.close
+            end
+        }
+        end
+    end
+end
+
+bs = BackShot.new "127.0.0.1", 8081
+bs.listen
diff --git a/server.rb b/server.rb
new file mode 100644
index 0000000..89ce7f5
--- /dev/null
+++ b/server.rb
@@ -0,0 +1,16 @@
+require 'socket'
+
+puts "Opening a TCP Server on port 8080..."
+
+TCPServer.open("127.0.0.1", 8080) { |server|
+    loop do
+        conn = server.accept
+        msg = conn.gets.chomp
+        puts msg
+        conn.puts "response"
+        conn.close
+        break if msg == "shutdown"
+    end
+}
+
+puts "Shutting down..."
diff --git a/srv.rb b/srv.rb
new file mode 100644
index 0000000..d0840f8
--- /dev/null
+++ b/srv.rb
@@ -0,0 +1,5 @@
+require './pipesocket'
+
+srv = PipeSocket.new("pipe1", "127.0.0.1", 8080)
+srv.listen
+srv.close
diff --git a/test.rb b/test.rb
new file mode 100644
index 0000000..87888e8
--- /dev/null
+++ b/test.rb
@@ -0,0 +1,4 @@
+File.open("happy.txt", "r+") { |file| 
+    file.write "i'm happy\n"
+}
+