Update plug.proto

Reviewed-on: https://git.dragse.it/anthrove/grpc-proto/pulls/2
Reviewed-by: Lennard Brinkhaus <lennard.brinkhaus@noreply.localhost>

plug.proto

@@ -1,4 +1,5 @@
 syntax = "proto3";
+import "google/protobuf/timestamp.proto";
 
 option go_package = "git.dragse.it/anthrove/plug-[REPLACE_ME]/api/gRPC";
 
@@ -6,6 +7,19 @@ service PlugConnector {
   rpc TaskStart(PlugTaskCreation) returns (PlugTaskStatus);
   rpc TaskStatus(PlugTask) returns (PlugTaskStatus);
   rpc TaskCancel(PlugTask) returns (PlugTaskStatus);
+  rpc Ping(PingRequest) returns (PongResponse);  // Added Ping endpoint
+  rpc SendMessage(SendMessageRequest) returns (SendMessageResponse);
+  rpc GetUserMessages(GetMessagesRequest) returns (GetMessagesResponse);
+}
+
+message PingRequest {
+  string message = 1; // Optional message field, can be removed if not needed
+  google.protobuf.Timestamp timestamp = 2;
+}
+
+message PongResponse {
+  string message = 1; // Optional message field, can be removed if not needed
+  google.protobuf.Timestamp timestamp = 2;
 }
 
 message PlugTaskStatus {
@@ -25,7 +39,31 @@ message PlugTask {
 }
 
 message PlugTaskCreation {
-  string user_id = 1;
-  string user_source_name = 2;
-  bool deep_scrape = 3;
+  string user_source_id = 1;
+  bool deep_scrape = 2;
+  string api_key = 3;
+}
+
+message SendMessageRequest {
+  string user_source_id = 1;
+  string message = 2;
+}
+
+message SendMessageResponse {
+  bool success = 1;
+}
+
+message GetMessagesRequest {
+  string user_source_id = 1;
+}
+
+message GetMessagesResponse {
+  repeated Message messages = 1;
+}
+
+message Message {
+  string from_user_source_id = 1;
+  google.protobuf.Timestamp created_at = 2;
+  string body = 3;
+  string title = 4;
 }