slack and google provider added

Author: mrasif

.github/workflows/go-tests.yaml

@@ -0,0 +1,23 @@
+name: Go Tests
+
+on:
+  push:
+    branches: [ 'main', 'develop' ]
+  pull_request:
+    branches: [ '*' ]
+
+jobs:
+  tests:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v2
+    - name: Set up Go
+      uses: actions/setup-go@v2
+      with:
+        go-version: 1.22
+    - name: Build
+      run: make build
+    - name: Test
+      run: make test
+    - name: Upload coverage to Codecov
+      uses: codecov/codecov-action@v2

.github/workflows/release.yaml

@@ -0,0 +1,56 @@
+name: Build and Release
+
+on:
+  push:
+    tags:
+      - 'v*.*.*'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    strategy:
+      matrix:
+        go-version: [1.22]
+
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v3
+
+    - name: Set up Go
+      uses: actions/setup-go@v4
+      with:
+        go-version: ${{ matrix.go-version }}
+
+    - name: Install dependencies
+      run: make install
+
+    - name: Build
+      run: make build-all
+
+    - name: Archive build artifacts
+      uses: actions/upload-artifact@v3
+      with:
+        name: build
+        path: build
+        if-no-files-found: error
+
+  release:
+    needs: build
+    runs-on: ubuntu-latest
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v3
+
+    - name: Download build artifacts
+      uses: actions/download-artifact@v3
+      with:
+        name: build
+        path: build
+
+    - name: Create GitHub Release
+      uses: softprops/action-gh-release@v1
+      with:
+        files: ./build/*
+      env:
+        GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -1,3 +1,4 @@
 build
 
 chat
+coverage.out

Makefile

@@ -0,0 +1,23 @@
+install:
+	go mod tidy
+
+test:
+	go test -v ./...  -race -coverprofile=coverage.out -covermode=atomic
+
+run: build
+	./chat "This is test."
+
+build:
+	go build -o chat .
+
+build-all:
+	GOOS=linux GOARCH=amd64 go build -o build/chat-linux-amd64
+	GOOS=linux GOARCH=arm64 go build -o build/chat-linux-arm64
+	GOOS=linux GOARCH=arm go build -o build/chat-linux-arm
+	GOOS=darwin GOARCH=amd64 go build -o build/chat-darwin-amd64
+	GOOS=darwin GOARCH=arm64 go build -o build/chat-darwin-arm64
+	GOOS=windows GOARCH=amd64 go build -o build/chat-windows-amd64.exe
+	GOOS=windows GOARCH=386 go build -o build/chat-windows-i386.exe
+
+clean:
+	rm -rf chat build

agents/agent.go

@@ -0,0 +1,7 @@
+package agents
+
+type Agent interface {
+    Post(message string) (interface{}, error)
+    Reply(threadId string, message string) (interface{}, error)
+}
+

agents/google.go

@@ -0,0 +1,68 @@
+package agents
+
+import (
+	"fmt"
+	"io"
+	"net/http"
+	"strings"
+
+	"github.com/tech-thinker/chat/config"
+)
+
+type googleAgent struct {
+    config *config.Config
+}
+
+func (agent *googleAgent) Post(message string) (interface{}, error) {
+    url := agent.config.GoogleWebHookURL
+
+	payloadStr := fmt.Sprintf(
+            `{"text": "%s"}`,
+            message,
+        )
+
+    payload := strings.NewReader(payloadStr)
+
+	req, _ := http.NewRequest("POST", url, payload)
+
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("User-Agent", "tech-thinker/chat")
+
+	res, err := http.DefaultClient.Do(req)
+    if err!=nil {
+        return nil, err
+    }
+
+	defer res.Body.Close()
+	body, err := io.ReadAll(res.Body)
+    return string(body), err
+}
+
+func (agent *googleAgent) Reply(threadId string, message string) (interface{}, error) {
+    url := fmt.Sprintf("%s&messageReplyOption=REPLY_MESSAGE_FALLBACK_TO_NEW_THREAD",agent.config.GoogleWebHookURL)
+
+	payloadStr := fmt.Sprintf(
+            `{"text": "%s", "thread": {"name": "%s"}}`,
+            message, threadId,
+        )
+
+    payload := strings.NewReader(payloadStr)
+
+	req, _ := http.NewRequest("POST", url, payload)
+
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("User-Agent", "tech-thinker/chat")
+
+	res, err := http.DefaultClient.Do(req)
+    if err!=nil {
+        return nil, err
+    }
+
+	defer res.Body.Close()
+	body, err := io.ReadAll(res.Body)
+    return string(body), err
+}
+
+func NewGoogleAgent(config *config.Config) Agent {
+    return &googleAgent{config: config}
+}

agents/slack.go

@@ -0,0 +1,70 @@
+package agents
+
+import (
+	"fmt"
+	"io"
+	"net/http"
+	"strings"
+
+	"github.com/tech-thinker/chat/config"
+)
+
+type slackAgent struct {
+    config *config.Config
+}
+
+func (agent *slackAgent) Post(message string) (interface{}, error) {
+    url := "https://slack.com/api/chat.postMessage"
+
+	payloadStr := fmt.Sprintf(
+            `{"channel": "%s","text": "%s"}`,
+            agent.config.SlackChannelId, message,
+        )
+
+    payload := strings.NewReader(payloadStr)
+
+	req, _ := http.NewRequest("POST", url, payload)
+
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("User-Agent", "tech-thinker/chat")
+	req.Header.Add("Authorization", fmt.Sprintf("Bearer %s", agent.config.SlackToken))
+
+	res, err := http.DefaultClient.Do(req)
+    if err!=nil {
+        return nil, err
+    }
+
+	defer res.Body.Close()
+	body, err := io.ReadAll(res.Body)
+    return string(body), err
+}
+
+func (agent *slackAgent) Reply(threadId string, message string) (interface{}, error) {
+    url := "https://slack.com/api/chat.postMessage"
+
+	payloadStr := fmt.Sprintf(
+            `{"channel": "%s", "text": "%s", "thread_ts": "%s"}`,
+            agent.config.SlackChannelId, message, threadId,
+        )
+
+    payload := strings.NewReader(payloadStr)
+
+	req, _ := http.NewRequest("POST", url, payload)
+
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("User-Agent", "tech-thinker/chat")
+	req.Header.Add("Authorization", fmt.Sprintf("Bearer %s", agent.config.SlackToken))
+
+	res, err := http.DefaultClient.Do(req)
+    if err!=nil {
+        return nil, err
+    }
+
+	defer res.Body.Close()
+	body, err := io.ReadAll(res.Body)
+    return string(body), err
+}
+
+func NewSlackAgent(config *config.Config) Agent {
+    return &slackAgent{config: config}
+}

chat.ini

@@ -0,0 +1,14 @@
+[default]
+PROVIDER=slack
+SLACK_TOKEN=
+CHANNEL_ID=
+
+[slack]
+PROVIDER=slack
+SLACK_TOKEN=
+CHANNEL_ID=
+
+[google]
+PROVIDER=google
+WEB_HOOK_URL=
+

config/config.go

@@ -0,0 +1,9 @@
+package config
+
+// Environment
+type Config struct {
+    Provider string
+    SlackToken string
+    SlackChannelId string
+    GoogleWebHookURL string
+}

go.mod

@@ -0,0 +1,33 @@
+module github.com/tech-thinker/chat
+
+go 1.23.0
+
+require (
+	github.com/spf13/viper v1.19.0
+	github.com/urfave/cli/v2 v2.27.4
+)
+
+require (
+	github.com/cpuguy83/go-md2man/v2 v2.0.4 // indirect
+	github.com/fsnotify/fsnotify v1.7.0 // indirect
+	github.com/hashicorp/hcl v1.0.0 // indirect
+	github.com/magiconair/properties v1.8.7 // indirect
+	github.com/mitchellh/mapstructure v1.5.0 // indirect
+	github.com/pelletier/go-toml/v2 v2.2.2 // indirect
+	github.com/russross/blackfriday/v2 v2.1.0 // indirect
+	github.com/sagikazarmark/locafero v0.4.0 // indirect
+	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
+	github.com/sourcegraph/conc v0.3.0 // indirect
+	github.com/spf13/afero v1.11.0 // indirect
+	github.com/spf13/cast v1.6.0 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
+	github.com/subosito/gotenv v1.6.0 // indirect
+	github.com/xrash/smetrics v0.0.0-20240521201337-686a1a2994c1 // indirect
+	go.uber.org/atomic v1.9.0 // indirect
+	go.uber.org/multierr v1.9.0 // indirect
+	golang.org/x/exp v0.0.0-20230905200255-921286631fa9 // indirect
+	golang.org/x/sys v0.18.0 // indirect
+	golang.org/x/text v0.14.0 // indirect
+	gopkg.in/ini.v1 v1.67.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)