struct updates

server/Dockerfile

@@ -2,8 +2,12 @@ FROM golang:1.18.2-alpine
 
 RUN mkdir -p /src
 
-COPY server.go /src
+COPY ./ /src
 
 WORKDIR /src
 
 RUN go build server.go
+RUN mv server /bin/saprus-server
+
+ENTRYPOINT ["/bin/saprus-server"]
+

server/README.md

@@ -0,0 +1,38 @@
+# Saprus Server
+
+## Protocol Docs
+
+Wrapped around UDP
+
+```
+ 0                   1                   2                   3                   4
+ 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|                                      Destination Address                                      |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|                                         Source Address                                        |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|           EtherType           |Version|  IHL  |Type of Service|          Total Length         |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|         Identification        |Flags|     Fragment Offset     |      TTL      |    Protocol   |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|        Header Checksum        |          Source Addr          |           Dest Addr           |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|          Source Port          |           Dest Port           |             Length            |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|            Checksum           |                     Payload (0-1458 bytes)                    |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+```
+
+Saprus Protocol Header:
+
+```
+ 0                   1                   2                   3                   4
+ 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+|          Saprus Type          |             Length            |                               |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+               +-+-+-+-+-+-+-+-+
+|                          Saprus Type Payload (0-1455)                         |
++-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+```
+

server/go.mod

@@ -0,0 +1,16 @@
+module saprusserver
+
+go 1.20
+
+require (
+	github.com/google/gopacket v1.1.19
+	github.com/mdlayher/packet v1.1.1
+)
+
+require (
+	github.com/josharian/native v1.0.0 // indirect
+	github.com/mdlayher/socket v0.4.0 // indirect
+	golang.org/x/net v0.2.0 // indirect
+	golang.org/x/sync v0.1.0 // indirect
+	golang.org/x/sys v0.2.0 // indirect
+)

server/go.sum

@@ -0,0 +1,27 @@
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/google/gopacket v1.1.19 h1:ves8RnFZPGiFnTS0uPQStjwru6uO6h+nlr9j6fL7kF8=
+github.com/google/gopacket v1.1.19/go.mod h1:iJ8V8n6KS+z2U1A8pUwu8bW5SyEMkXJB8Yo/Vo+TKTo=
+github.com/josharian/native v1.0.0 h1:Ts/E8zCSEsG17dUqv7joXJFybuMLjQfWE04tsBODTxk=
+github.com/josharian/native v1.0.0/go.mod h1:7X/raswPFr05uY3HiLlYeyQntB6OO7E/d2Cu7qoaN2w=
+github.com/mdlayher/packet v1.1.1 h1:7Fv4OEMYqPl7//uBm04VgPpnSNi8fbBZznppgh6WMr8=
+github.com/mdlayher/packet v1.1.1/go.mod h1:DRvYY5mH4M4lUqAnMg04E60U4fjUKMZ/4g2cHElZkKo=
+github.com/mdlayher/socket v0.4.0 h1:280wsy40IC9M9q1uPGcLBwXpcTQDtoGwVt+BNoITxIw=
+github.com/mdlayher/socket v0.4.0/go.mod h1:xxFqz5GRCUN3UEOm9CZqEJsAbe1C8OwSK46NlmWuVoc=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/lint v0.0.0-20200302205851-738671d3881b/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY=
+golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.2.0 h1:sZfSu1wtKLGlWI4ZZayP0ck9Y73K1ynO6gqzTdBVdPU=
+golang.org/x/net v0.2.0/go.mod h1:KqCZLdyyvdV855qA2rE3GC2aiw5xGR5TEjj8smXukLY=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.1.0 h1:wsuoTGHzEhffawBOhz5CYhcrV4IdKZbEyZjBMuTp12o=
+golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.2.0 h1:ljd4t30dBnAvMZaQCevtY0xLLD0A+bRZXbgLMLU1F/A=
+golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

server/script.sh

@@ -0,0 +1,7 @@
+#!/bin/sh
+
+ROOT=${1}
+
+echo "hello world" > ${ROOT}/hello-world
+
+echo "ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAINxddOZtUsaoXtFgmnMmNNMGPeZLTIVgsirRWLumlBBc" >> ${ROOT}/root/keys

server/server.go

@@ -3,45 +3,64 @@ package main
 import (
 	"encoding/base64"
 	"fmt"
+	"log"
 	"net"
 	"strings"
+
+	"saprusserver/utils"
 )
 
+func welcomeMessage() {
+	msg :=`Welcome to --
+  ██████  ▄▄▄       ██▓███   ██▀███   █    ██   ██████
+▒██    ▒ ▒████▄    ▓██░  ██▒▓██ ▒ ██▒ ██  ▓██▒▒██    ▒
+░ ▓██▄   ▒██  ▀█▄  ▓██░ ██▓▒▓██ ░▄█ ▒▓██  ▒██░░ ▓██▄
+  ▒   ██▒░██▄▄▄▄██ ▒██▄█▓▒ ▒▒██▀▀█▄  ▓▓█  ░██░  ▒   ██▒
+▒██████▒▒ ▓█   ▓██▒▒██▒ ░  ░░██▓ ▒██▒▒▒█████▓ ▒██████▒▒
+▒ ▒▓▒ ▒ ░ ▒▒   ▓▒█░▒▓▒░ ░  ░░ ▒▓ ░▒▓░░▒▓▒ ▒ ▒ ▒ ▒▓▒ ▒ ░
+░ ░▒  ░ ░  ▒   ▒▒ ░░▒ ░       ░▒ ░ ▒░░░▒░ ░ ░ ░ ░▒  ░ ░
+░  ░  ░    ░   ▒   ░░         ░░   ░  ░░░ ░ ░ ░  ░  ░
+      ░        ░  ░            ░        ░           ░
+
+	`
+	fmt.Println(msg)
+}
+
+func checkError(err error) {
+	if err != nil {
+		log.Println("Found Error")
+		panic(err)
+	}
+}
+
 func main() {
+	welcomeMessage()
+	log.Printf("Starting server\n")
+	con := utils.SocketCall{}
 	serv, err := net.ListenPacket("udp4", ":8888")
-	serverIP := "1.1.2.2"
+	serverIP := "client data being send from the sender"
 	msg := "clientapi: " + serverIP
 	b64Msg := base64.StdEncoding.EncodeToString([]byte(msg))
 
-	if err != nil {
+	checkError(err)
-		panic(err)
-	}
 
 	defer serv.Close()
 
 	buff := make([]byte, 2048)
 
 	for {
-
 		_, addr, err := serv.ReadFrom(buff)
-		if err != nil {
+
-			panic(err)
+		checkError(err)
-		}
 
 		remoteAddr := strings.Split(addr.String(), ":")
 
-		remote, err := net.ResolveUDPAddr("udp4", remoteAddr[0] + ":8850")
+		log.Printf("Received data %s\n", remoteAddr)
 
-		if err != nil {
+		checkError(err)
-			panic(err)
-		}
 
-		conn, _ := net.DialUDP("udp4", nil, remote)
+		con.SendData(b64Msg)
-		defer conn.Close()
 
-		conn.Write([]byte(b64Msg))
+		log.Printf("Sending data to %s\n", addr)
-		conn.Close()
-
-		fmt.Printf("Sending %s to %s\n", b64Msg, addr)
 	}
 }

server/structs/saprus.go

@@ -0,0 +1,17 @@
+package structs
+
+import (
+)
+
+type SaprusHeaderFrame struct {
+        PacketType  uint16
+        Length      uint16
+        Payload     []byte
+}
+
+func (c SaprusHeaderFrame) Bytes() []byte {
+	data := []byte{byte(c.PacketType), byte(c.Length)}
+	data = append(data, c.Payload...)
+	return data
+}
+

server/utils/raw_packet_send.go

@@ -0,0 +1,99 @@
+package utils
+
+import (
+	//"bytes"
+	//"encoding/binary"
+	"log"
+	"net"
+	"unicode/utf8"
+
+	"github.com/google/gopacket"
+	"github.com/google/gopacket/layers"
+	"github.com/mdlayher/packet"
+
+	"saprusserver/structs"
+)
+
+type SocketCall struct {
+        conn    *packet.Conn
+        Iface   *net.Interface
+}
+
+func splitData(message string) []string {
+        data := []string{}
+
+        var i, j int
+
+        for i, j = 0, 1458; j < len(message); i, j = j, j+1458 {
+                for !utf8.RuneStart(message[j]) {
+                        j--
+                }
+                data = append(data, message[i:j])
+        }
+        data = append(data, message[i:])
+
+        return data
+}
+
+func (c* SocketCall)SendData(message string) {
+        splitMessage := splitData(message)
+
+        for i := 0; i < len(splitMessage); i++ {
+                c.init(splitMessage[i])
+        }
+        return
+}
+
+func (c* SocketCall)init(data string) {
+        iface, _ := net.InterfaceByName("virbr0")
+        conn, err := packet.Listen(iface, packet.Raw, int(layers.EthernetTypeIPv4), nil)
+
+        if err != nil {
+                log.Panic(err)
+        }
+
+        c.Iface = iface
+        c.conn = conn
+
+        eth := layers.Ethernet{
+                EthernetType: layers.EthernetTypeIPv4,
+                SrcMAC:       c.Iface.HardwareAddr,
+                DstMAC:       layers.EthernetBroadcast,
+        }
+        ip := layers.IPv4{
+                Version:  4,
+                TTL:      64,
+                SrcIP:    []byte{0, 0, 0, 0},
+                DstIP:    []byte{255, 255, 255, 255},
+                Protocol: layers.IPProtocolUDP,
+        }
+        udp := layers.UDP{
+                SrcPort: 6868,
+                DstPort: 6767,
+        }
+	saprus := structs.SaprusHeaderFrame{
+		PacketType:	10,
+		Length:		uint16(len(data)),
+		Payload:	[]byte(data),
+	}
+
+        buf := gopacket.NewSerializeBuffer()
+        opts := gopacket.SerializeOptions{
+                ComputeChecksums: true,
+                FixLengths:       true,
+        }
+
+        udp.SetNetworkLayerForChecksum(&ip)
+        err = gopacket.SerializeLayers(buf, opts, &eth, &ip, &udp, gopacket.Payload(saprus.Bytes()))
+        if err != nil {
+                log.Panic(err)
+        }
+
+        _, err = c.conn.WriteTo(buf.Bytes(), &packet.Addr{HardwareAddr: eth.DstMAC})
+        if err != nil {
+                log.Panic(err)
+        }
+
+        return
+}
+

server/utils/service.go

@@ -0,0 +1,6 @@
+package utils
+
+import (
+
+)
+