feat: add send location (#43)

* feat: add send location

* feat: update frontend

* feat: update docs

* feat: update docs

* fix: logout remove file

* fix: remove gitignore

* fix: send video

* feat: add context in validation

Author: aldinokemal

docs/openapi.yaml

@@ -1,7 +1,7 @@
 openapi: 3.0.0
 info:
   title: WhatsApp API MultiDevice
-  version: 3.0.0
+  version: 3.1.0
   description: This API is used for sending whatsapp via API
 servers:
   - url: http://localhost:3000
@@ -566,6 +566,49 @@ paths:
             application/json:
               schema:
                 $ref: '#/components/schemas/ErrorInternalServer'
+  /send/location:
+    post:
+      operationId: sendLocation
+      tags:
+        - message
+      summary: Send Location
+      requestBody:
+        content:
+          multipart/form-data:
+            schema:
+              type: object
+              properties:
+                phone:
+                  type: integer
+                  example: '6289685024051@s.whatsapp.net'
+                  description: Phone number with country code
+                latitude:
+                  type: string
+                  example: "-7.797068"
+                  description: Latitude coordinate
+                longitude:
+                  type: string
+                  example: '110.370529'
+                  description: Longitude coordinate
+      responses:
+        '200':
+          description: OK
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/SendResponse'
+        '400':
+          description: Bad Request
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/ErrorBadRequest'
+        '500':
+          description: Internal Server Error
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/ErrorInternalServer'
   /message/:message_id/revoke:
     post:
       operationId: revokeMessage

readme.md

@@ -107,7 +107,8 @@ API using [openapi-generator](https://openapi-generator.tech/#try)
 | ✅       | Send Video              | POST   | /send/video                 | 
 | ✅       | Send Contact            | POST   | /send/contact               |
 | ✅       | Send Link               | POST   | /send/link                  |
-| ✅       | Revoke Messave          | POST   | /message/:message_id/revoke |
+| ✅       | Send Location           | POST   | /send/location              |
+| ✅       | Revoke Message          | POST   | /message/:message_id/revoke |
 
 ```
 ✅ = Available
@@ -116,20 +117,21 @@ API using [openapi-generator](https://openapi-generator.tech/#try)
 
 ### App User Interface
 
-1. Homepage ![Homepage](https://i.ibb.co/NNX2wWY/home.png)
+1. Homepage ![Homepage](https://i.ibb.co/GMNWqRq/homepage.png)
 2. Login ![Login](https://i.ibb.co/jkcB15R/login.png)
-3. Send Message ![Send Message](https://i.ibb.co/DrCVXS7/send-message.png)
-4. Send Image ![Send Image](https://i.ibb.co/WykfQc8/send-image.png)
-5. Send File ![Send File](https://i.ibb.co/wC4SfRp/send-file.png)
-6. Send Video ![Send Video](https://i.ibb.co/VDCRH3G/send-video.png)
+3. Send Message ![Send Message](https://i.ibb.co/rc3NXMX/send-message.png)
+4. Send Image ![Send Image](https://i.ibb.co/BcFL3SD/send-image.png)
+5. Send File ![Send File](https://i.ibb.co/f4yxjpp/send-file.png)
+6. Send Video ![Send Video](https://i.ibb.co/PrD3P51/send-video.png)
 7. Send Contact ![Send Contact](https://i.ibb.co/4810H7N/send-contact.png)
-8. Revoke Message ![Revoke Message](https://i.ibb.co/yswhvQY/revoke.png?)
-9. User Info ![User Info](https://i.ibb.co/3zjX6Cz/user-info.png)
-10. User Avatar ![User Avatar](https://i.ibb.co/cysjmjT/user-avatar.png?)
-11. My Privacy ![My Privacy](https://i.ibb.co/Cw1sMQz/my-privacy.png)
-12. My Group ![My Group](https://i.ibb.co/B6rW8Sh/list-group.png)
-13. Auto Reply ![Auto Reply](https://i.ibb.co/D4rTytX/IMG-20220517-162500.jpg)
-14. Basic Auth Prompt ![Basic Auth](https://i.ibb.co/PDjQ92W/Screenshot-2022-11-06-at-14-06-29.png)
+8. Send Location ![Send Location](https://i.ibb.co/TWsy09G/send-location.png)
+9. Revoke Message ![Revoke Message](https://i.ibb.co/yswhvQY/revoke.png?)
+10. User Info ![User Info](https://i.ibb.co/3zjX6Cz/user-info.png)
+11. User Avatar ![User Avatar](https://i.ibb.co/cysjmjT/user-avatar.png?)
+12. My Privacy ![My Privacy](https://i.ibb.co/Cw1sMQz/my-privacy.png)
+13. My Group ![My Group](https://i.ibb.co/B6rW8Sh/list-group.png)
+14. Auto Reply ![Auto Reply](https://i.ibb.co/D4rTytX/IMG-20220517-162500.jpg)
+15. Basic Auth Prompt ![Basic Auth](https://i.ibb.co/PDjQ92W/Screenshot-2022-11-06-at-14-06-29.png)
 
 ### Mac OS NOTE
 

src/config/settings.go

@@ -6,7 +6,7 @@ import (
 )
 
 var (
-	AppVersion             = "v4.2.0"
+	AppVersion             = "v4.3.0"
 	AppPort                = "3000"
 	AppDebug               = false
 	AppOs                  = fmt.Sprintf("AldinoKemal")

src/domains/send/location.go

@@ -0,0 +1,12 @@
+package send
+
+type LocationRequest struct {
+	Phone     string `json:"phone" form:"phone"`
+	Latitude  string `json:"latitude" form:"latitude"`
+	Longitude string `json:"longitude" form:"longitude"`
+}
+
+type LocationResponse struct {
+	MessageID string `json:"message_id"`
+	Status    string `json:"status"`
+}

src/domains/send/send.go

@@ -11,6 +11,7 @@ type ISendService interface {
 	SendVideo(ctx context.Context, request VideoRequest) (response VideoResponse, err error)
 	SendContact(ctx context.Context, request ContactRequest) (response ContactResponse, err error)
 	SendLink(ctx context.Context, request LinkRequest) (response LinkResponse, err error)
+	SendLocation(ctx context.Context, request LocationRequest) (response LocationResponse, err error)
 	Revoke(ctx context.Context, request RevokeRequest) (response RevokeResponse, err error)
 	UpdateMessage(ctx context.Context, request UpdateMessageRequest) (response UpdateMessageResponse, err error)
 }

src/internal/rest/send.go

@@ -19,6 +19,7 @@ func InitRestSend(app *fiber.App, service domainSend.ISendService) Send {
 	app.Post("/send/video", rest.SendVideo)
 	app.Post("/send/contact", rest.SendContact)
 	app.Post("/send/link", rest.SendLink)
+	app.Post("/send/location", rest.SendLocation)
 	app.Post("/message/:message_id/revoke", rest.RevokeMessage)
 	app.Post("/message/:message_id/update", rest.UpdateMessage)
 	return rest
@@ -140,6 +141,23 @@ func (controller *Send) SendLink(c *fiber.Ctx) error {
 	})
 }
 
+func (controller *Send) SendLocation(c *fiber.Ctx) error {
+	var request domainSend.LocationRequest
+	err := c.BodyParser(&request)
+	utils.PanicIfNeeded(err)
+
+	whatsapp.SanitizePhone(&request.Phone)
+
+	response, err := controller.Service.SendLocation(c.UserContext(), request)
+	utils.PanicIfNeeded(err)
+
+	return c.JSON(utils.ResponseData{
+		Status:  200,
+		Message: response.Status,
+		Results: response,
+	})
+}
+
 func (controller *Send) RevokeMessage(c *fiber.Ctx) error {
 	var request domainSend.RevokeRequest
 	err := c.BodyParser(&request)

src/pkg/utils/general.go

@@ -4,6 +4,8 @@ import (
 	"fmt"
 	"os"
 	"path/filepath"
+	"strconv"
+	"strings"
 	"time"
 )
 
@@ -46,3 +48,11 @@ func PanicIfNeeded(err any, message ...string) {
 		}
 	}
 }
+
+func StrToFloat64(text string) float64 {
+	var result float64
+	if text != "" {
+		result, _ = strconv.ParseFloat(strings.TrimSpace(text), 64)
+	}
+	return result
+}

src/pkg/whatsapp/whatsapp.go

@@ -240,7 +240,7 @@ func handler(rawEvt interface{}) {
 		}
 	case *events.HistorySync:
 		id := atomic.AddInt32(&historySyncID, 1)
-		fileName := fmt.Sprintf("%s/history-%d-%d.json", config.PathStorages, startupTime, id)
+		fileName := fmt.Sprintf("%s/history-%d-%s-%d-%s.json", config.PathStorages, startupTime, cli.Store.ID.String(), id, evt.Data.SyncType.String())
 		file, err := os.OpenFile(fileName, os.O_WRONLY|os.O_CREATE, 0600)
 		if err != nil {
 			log.Errorf("Failed to open file to write history sync: %v", err)

src/services/app.go

@@ -12,6 +12,7 @@ import (
 	"go.mau.fi/whatsmeow/store/sqlstore"
 	"os"
 	"path/filepath"
+	"strings"
 	"time"
 )
 
@@ -86,7 +87,7 @@ func (service serviceApp) Login(_ context.Context) (response domainApp.LoginResp
 
 func (service serviceApp) Logout(_ context.Context) (err error) {
 	// delete history
-	files, err := filepath.Glob("./history-*")
+	files, err := filepath.Glob(fmt.Sprintf("./%s/history-*", config.PathStorages))
 	if err != nil {
 		return err
 	}
@@ -98,7 +99,7 @@ func (service serviceApp) Logout(_ context.Context) (err error) {
 		}
 	}
 	// delete qr images
-	qrImages, err := filepath.Glob("./statics/images/qrcode/scan-*")
+	qrImages, err := filepath.Glob(fmt.Sprintf("./%s/scan-*", config.PathQrCode))
 	if err != nil {
 		return err
 	}
@@ -110,6 +111,21 @@ func (service serviceApp) Logout(_ context.Context) (err error) {
 		}
 	}
 
+	// delete senditems
+	qrItems, err := filepath.Glob(fmt.Sprintf("./%s/*", config.PathSendItems))
+	if err != nil {
+		return err
+	}
+
+	for _, f := range qrItems {
+		if !strings.Contains(f, ".gitignore") {
+			err = os.Remove(f)
+			if err != nil {
+				return err
+			}
+		}
+	}
+
 	err = service.WaCli.Logout()
 	return
 }

src/services/send.go

@@ -32,7 +32,7 @@ func NewSendService(waCli *whatsmeow.Client) domainSend.ISendService {
 }
 
 func (service serviceSend) SendText(ctx context.Context, request domainSend.MessageRequest) (response domainSend.MessageResponse, err error) {
-	err = validations.ValidateSendMessage(request)
+	err = validations.ValidateSendMessage(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -54,7 +54,7 @@ func (service serviceSend) SendText(ctx context.Context, request domainSend.Mess
 }
 
 func (service serviceSend) SendImage(ctx context.Context, request domainSend.ImageRequest) (response domainSend.ImageResponse, err error) {
-	err = validations.ValidateSendImage(request)
+	err = validations.ValidateSendImage(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -152,7 +152,7 @@ func (service serviceSend) SendImage(ctx context.Context, request domainSend.Ima
 }
 
 func (service serviceSend) SendFile(ctx context.Context, request domainSend.FileRequest) (response domainSend.FileResponse, err error) {
-	err = validations.ValidateSendFile(request)
+	err = validations.ValidateSendFile(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -207,7 +207,7 @@ func (service serviceSend) SendFile(ctx context.Context, request domainSend.File
 }
 
 func (service serviceSend) SendVideo(ctx context.Context, request domainSend.VideoRequest) (response domainSend.VideoResponse, err error) {
-	err = validations.ValidateSendVideo(request)
+	err = validations.ValidateSendVideo(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -286,20 +286,23 @@ func (service serviceSend) SendVideo(ctx context.Context, request domainSend.Vid
 
 	msgId := whatsmeow.GenerateMessageID()
 	msg := &waProto.Message{VideoMessage: &waProto.VideoMessage{
-		Url:           proto.String(uploaded.URL),
-		Mimetype:      proto.String(http.DetectContentType(dataWaVideo)),
-		Caption:       proto.String(request.Caption),
-		FileLength:    proto.Uint64(uploaded.FileLength),
-		FileSha256:    uploaded.FileSHA256,
-		FileEncSha256: uploaded.FileEncSHA256,
-		MediaKey:      uploaded.MediaKey,
-		DirectPath:    proto.String(uploaded.DirectPath),
-		ViewOnce:      proto.Bool(request.ViewOnce),
-		JpegThumbnail: dataWaThumbnail,
+		Url:                 proto.String(uploaded.URL),
+		Mimetype:            proto.String(http.DetectContentType(dataWaVideo)),
+		Caption:             proto.String(request.Caption),
+		FileLength:          proto.Uint64(uploaded.FileLength),
+		FileSha256:          uploaded.FileSHA256,
+		FileEncSha256:       uploaded.FileEncSHA256,
+		MediaKey:            uploaded.MediaKey,
+		DirectPath:          proto.String(uploaded.DirectPath),
+		ViewOnce:            proto.Bool(request.ViewOnce),
+		JpegThumbnail:       dataWaThumbnail,
+		ThumbnailEncSha256:  dataWaThumbnail,
+		ThumbnailSha256:     dataWaThumbnail,
+		ThumbnailDirectPath: proto.String(uploaded.DirectPath),
 	}}
 	ts, err := service.WaCli.SendMessage(ctx, dataWaRecipient, msgId, msg)
 	go func() {
-		errDelete := utils.RemoveFile(0, deletedItems...)
+		errDelete := utils.RemoveFile(1, deletedItems...)
 		if errDelete != nil {
 			fmt.Println(errDelete)
 		}
@@ -314,7 +317,7 @@ func (service serviceSend) SendVideo(ctx context.Context, request domainSend.Vid
 }
 
 func (service serviceSend) SendContact(ctx context.Context, request domainSend.ContactRequest) (response domainSend.ContactResponse, err error) {
-	err = validations.ValidateSendContact(request)
+	err = validations.ValidateSendContact(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -341,7 +344,7 @@ func (service serviceSend) SendContact(ctx context.Context, request domainSend.C
 }
 
 func (service serviceSend) SendLink(ctx context.Context, request domainSend.LinkRequest) (response domainSend.LinkResponse, err error) {
-	err = validations.ValidateSendLink(request)
+	err = validations.ValidateSendLink(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -372,8 +375,38 @@ func (service serviceSend) SendLink(ctx context.Context, request domainSend.Link
 	return response, nil
 }
 
-func (service serviceSend) Revoke(_ context.Context, request domainSend.RevokeRequest) (response domainSend.RevokeResponse, err error) {
-	err = validations.ValidateRevokeMessage(request)
+func (service serviceSend) SendLocation(ctx context.Context, request domainSend.LocationRequest) (response domainSend.LocationResponse, err error) {
+	err = validations.ValidateSendLocation(ctx, request)
+	if err != nil {
+		return response, err
+	}
+	dataWaRecipient, err := whatsapp.ValidateJidWithLogin(service.WaCli, request.Phone)
+	if err != nil {
+		return response, err
+	}
+
+	// Compose WhatsApp Proto
+	msgId := whatsmeow.GenerateMessageID()
+	msg := &waProto.Message{
+		LocationMessage: &waProto.LocationMessage{
+			DegreesLatitude:  proto.Float64(utils.StrToFloat64(request.Latitude)),
+			DegreesLongitude: proto.Float64(utils.StrToFloat64(request.Longitude)),
+		},
+	}
+
+	// Send WhatsApp Message Proto
+	ts, err := service.WaCli.SendMessage(ctx, dataWaRecipient, msgId, msg)
+	if err != nil {
+		return response, err
+	}
+
+	response.MessageID = msgId
+	response.Status = fmt.Sprintf("Send location success %s (server timestamp: %s)", request.Phone, ts)
+	return response, nil
+}
+
+func (service serviceSend) Revoke(ctx context.Context, request domainSend.RevokeRequest) (response domainSend.RevokeResponse, err error) {
+	err = validations.ValidateRevokeMessage(ctx, request)
 	if err != nil {
 		return response, err
 	}
@@ -394,7 +427,7 @@ func (service serviceSend) Revoke(_ context.Context, request domainSend.RevokeRe
 }
 
 func (service serviceSend) UpdateMessage(ctx context.Context, request domainSend.UpdateMessageRequest) (response domainSend.UpdateMessageResponse, err error) {
-	err = validations.ValidateUpdateMessage(request)
+	err = validations.ValidateUpdateMessage(ctx, request)
 	if err != nil {
 		return response, err
 	}