Mercurial
view gara/main.go @ 279:b3b547563ec7
Add Google connector service and agent wiki
Implement the C/Seobeo Google Drive and Gmail connector with encrypted OAuth storage, Zenbu authentication, browser testing, AI tool discovery, chunked HTTP decoding, and Bazel coverage. Consolidate repository guidance into progressive wiki documentation and enforce arena-first allocation for new first-party C code.
Co-authored-by: Copilot <[email protected]>
Copilot-Session: 84c338fd-0939-4bb3-b7f3-1062eb213e5d
| author | MrJuneJune <me@mrjunejune.com> |
|---|---|
| date | Mon, 17 Aug 2026 22:22:36 -0700 |
| parents | c2706ffb442b |
| children |
line wrap: on
line source
package main import ( "fmt" "bytes" "net" ) type Client struct { name string conn net.Conn message []byte } var clients map[string]Client = make(map[string]Client) var allowedCharacters = map[byte]bool{ 'a': true, 'b': true, 'c': true, 'd': true, 'e': true, 'f': true, 'g': true, 'h': true, 'i': true, 'j': true, 'k': true, 'l': true, 'm': true, 'n': true, 'o': true, 'p': true, 'q': true, 'r': true, 's': true, 't': true, 'u': true, 'v': true, 'w': true, 'x': true, 'y': true, 'z': true, 'A': true, 'B': true, 'C': true, 'D': true, 'E': true, 'F': true, 'G': true, 'H': true, 'I': true, 'J': true, 'K': true, 'L': true, 'M': true, 'N': true, 'O': true, 'P': true, 'Q': true, 'R': true, 'S': true, 'T': true, 'U': true, 'V': true, 'W': true, 'X': true, 'Y': true, 'Z': true, } func IsChacterAllowed(chars []byte) bool { for _, b := range chars { if !allowedCharacters[b] { return false } } return true } func ResetClient(client Client) { ResetClientMessage(client) delete(clients, client.conn.RemoteAddr().String()) client.conn.Close() } func ResetClientMessage(client Client) { for i := range client.message { client.message[i] = 0 } } func Loggers(value string) { fmt.Println(value) } func SendString(client Client, value string) { fmt.Println("Notifying User: ", client.name) client.conn.Write(([]byte)(value+"\n")) } func SendToAll(currentClient Client) { for key, client := range clients { if currentClient.conn.RemoteAddr().String() == key { continue } formattedMessage := fmt.Sprintf("%v: %v", currentClient.name, (string)(currentClient.message)) SendString(client, formattedMessage) } } func HandleConnection(conn net.Conn) { client := Client{name: "unknown", conn: conn, message: make([]byte, 100)} defer ResetClient(client) SendString(client, "Hello good sir. What is your name?(less than 100 character and no special characters)\n") for { _, err := conn.Read(client.message) if err != nil { SendString(client, "Something went wrong. Try again.") continue } for i := 0; i < len(client.message) - 1; i++ { if (string)(client.message[i:i+2]) == "\r\n" { client.name = (string)(client.message[:i]) break; } } if !IsChacterAllowed(([]byte)(client.name)) { SendString(client, "Only allow alphabets.") continue } if client.name[0] == (byte)('\r') { continue } ResetClientMessage(client) break } clients[client.conn.RemoteAddr().String()] = client // Hnadle all messages. for { err_n := 0 if err_n > 10 { break; } _, err := conn.Read(client.message) if err != nil { Loggers("Something went wrong") err_n += 1 } if bytes.Equal(([]byte)("close"), client.message[:5]) { break } else { fmt.Println("Working....") SendToAll(client) } } } func main() { PORT := ":4200"; server_conn, err := net.Listen("tcp", PORT) fmt.Println("Running on ", server_conn.Addr().String()) if err != nil { Loggers("Couldn't run the server") } for { conn, err := server_conn.Accept() if err != nil { Loggers("Couldn't accept a client") } go HandleConnection(conn) } }