feat: new commands

Author: SugamKuber

README.md

@@ -22,7 +22,9 @@ This function will diconnect from chrono db
 
 3. CreateStream <<**CHRONO_NAME** *string* :: **STREAM_NAME** *string*>>
 
-4. WriteEvent <<**CHRONO_NAME** *string* :: **STREAM_NAME** *string* :: **EVENTS** { **HEADER**, **BODY** *(string, string)* } >>
+4. WriteEvent 
+
+<<**CHRONO_NAME** *string* :: **STREAM_NAME** *string* :: **EVENTS** { **HEADER**, **BODY** *(string, string)* } >>
 
 5. Read <<**CHRONO_NAME** *string* :: **STREAM_NAME** *string*>>
 

client/client.go

@@ -21,37 +21,28 @@ func (c *Client) Close() error {
 	return c.conn.Close()
 }
 
-func (c *Client) CreateChrono(chrono string) error {
-	if response, err := c.conn.Execute("cc " + "heheh"); err != nil || response != "OK" {
-		return fmt.Errorf("create failed: %v", err)
-	}
-	return nil
-}
-
 func (c *Client) CreateStream(chrono string, stream string) error {
-	if response, err := c.conn.Execute("cs " + stream); err != nil || response != "OK" {
+	if response, err := c.conn.Execute("CREATE STREAM " + stream); err != nil || response != "OK" {
 		return fmt.Errorf("create failed: %v", err)
 	}
 	return nil
 }
 func (c *Client) DeleteStream(chrono string, stream string) error {
-	if response, err := c.conn.Execute("ds " + stream); err != nil || response != "OK" {
+	if response, err := c.conn.Execute("DELETE STREAM " + stream); err != nil || response != "OK" {
 		return fmt.Errorf("delete failed: %v", err)
 	}
 	return nil
 }
 
-func (c *Client) WriteEvent(chrono string, stream string, data map[string]string) error {
-	command := "w " + stream + " "
-	for k, v := range data {
-		command += k + " " + v + " "
-	}
+func (c *Client) WriteEvent(chrono string, stream string, event string) error {
+	command := "INSERT " + event + " INTO " + stream
+	fmt.Println(command+"this is cm")
 	if response, err := c.conn.Execute(command); err != nil || response != "OK" {
 		return fmt.Errorf("write failed: %v", err)
 	}
 	return nil
 }
 
 func (c *Client) Read(chrono string, stream string) (string, error) {
-	return c.conn.Execute("r " + stream)
+	return c.conn.Execute("SELECT * FROM " + stream)
 }