Compare commits
5 Commits
Author | SHA1 | Date |
---|---|---|
soukainna | 0e42bd7f79 | |
Nicolas CARON | 23c7b50d9b | |
Nicolas CARON | 3028dde959 | |
mfrigo | c71851add2 | |
mfrigo | 86df552bd1 |
|
@ -0,0 +1,81 @@
|
|||
name: Build and Push Docker Image
|
||||
|
||||
on:
|
||||
push:
|
||||
tags:
|
||||
- '*'
|
||||
branches:
|
||||
- main
|
||||
- dev
|
||||
|
||||
jobs:
|
||||
build_and_push:
|
||||
runs-on: ubuntu-latest
|
||||
|
||||
steps:
|
||||
- name: Install Docker
|
||||
run: |
|
||||
apt-get update
|
||||
apt-get install -y docker.io
|
||||
|
||||
- name: Checkout Repository
|
||||
uses: actions/checkout@v4
|
||||
|
||||
- name: Set Kubernetes Context
|
||||
uses: azure/k8s-set-context@v4
|
||||
with:
|
||||
method: kubeconfig
|
||||
kubeconfig: ${{secrets.buildx_kubeconfig}}
|
||||
|
||||
- name: Set up Docker Buildx
|
||||
uses: docker/setup-buildx-action@v3
|
||||
with:
|
||||
driver: kubernetes
|
||||
driver-opts: |
|
||||
namespace=gitea
|
||||
|
||||
- name: Login to Docker Registry
|
||||
uses: docker/login-action@v3
|
||||
with:
|
||||
registry: git.coopgo.io
|
||||
username: ${{ secrets.REGISTRY_USER }}
|
||||
password: ${{ secrets.REGISTRY_TOKEN }}
|
||||
|
||||
- name: Extract metadata (tags, labels) for Docker image
|
||||
id: metadata
|
||||
uses: docker/metadata-action@v3
|
||||
with:
|
||||
images: git.coopgo.io/${{gitea.repository}}
|
||||
tags: |
|
||||
type=ref,event=branch
|
||||
type=ref,event=tag
|
||||
type=ref,event=pr
|
||||
flavor: |
|
||||
latest=auto
|
||||
|
||||
- name: Build and push
|
||||
uses: docker/build-push-action@v5
|
||||
with:
|
||||
context: .
|
||||
push: true
|
||||
tags: |
|
||||
${{ steps.metadata.outputs.tags }}
|
||||
build-args: |
|
||||
ACCESS_TOKEN_USR=${{gitea.actor}}
|
||||
ACCESS_TOKEN_PWD=${{gitea.token}}
|
||||
|
||||
# BUILD WITH KANIKO
|
||||
# - name: Kaniko build and push
|
||||
# uses: aevea/action-kaniko@master
|
||||
# with:
|
||||
# build_file: Dockerfile
|
||||
# registry: git.coopgo.io
|
||||
# username: ${{secrets.registry_user}}
|
||||
# password: ${{secrets.registry_token}}
|
||||
# image: ${{gitea.repository}}
|
||||
# tag: ${{gitea.ref_name}}
|
||||
# cache: true
|
||||
# cache_registry: git.coopgo.io/${{gitea.repository}}/cache
|
||||
# extra-args: |
|
||||
# ACCESS_TOKEN_USR=${{gitea.actor}}
|
||||
# ACCESS_TOKEN_PWD=${{gitea.token}}
|
|
@ -59,6 +59,7 @@ func (h AgendaHandler) SubscribeEvent(eventid string, subscriber string, data ma
|
|||
subscription := storage.Subscription{
|
||||
ID: id,
|
||||
Subscriber: subscriber,
|
||||
EventID: eventid,
|
||||
Tags: []string{},
|
||||
CreatedAt: now,
|
||||
Data: map[string]any{},
|
||||
|
@ -80,6 +81,7 @@ func (h AgendaHandler) DeleteSubscription(eventid string, subscriber string, dat
|
|||
deletesubscription := storage.Subscription{
|
||||
ID: id,
|
||||
Subscriber: subscriber,
|
||||
EventID: eventid,
|
||||
Tags: []string{},
|
||||
CreatedAt: now,
|
||||
Data: map[string]any{},
|
||||
|
@ -101,6 +103,17 @@ func (h AgendaHandler) UpdateEvent(event storage.Event) (*storage.Event, error)
|
|||
return &event, nil
|
||||
}
|
||||
|
||||
func (h AgendaHandler) GetSubscriber(subscriber string) (results []storage.Subscription, err error) {
|
||||
if subscriber == "" {
|
||||
return nil, errors.New("missing subscriber")
|
||||
}
|
||||
results, err = h.storage.GetSubscriber(subscriber)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return results, nil
|
||||
}
|
||||
|
||||
func (h AgendaHandler) GetSubscriptionByUser(subscriber string) (results []storage.Subscription, err error) {
|
||||
if subscriber == "" {
|
||||
return nil, errors.New("missing subscriber")
|
||||
|
|
|
@ -154,10 +154,81 @@ func (s MongoDBStorage) UpdateEvent(event Event) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (psql MongoDBStorage) GetSubscriber(subscriber string) ([]Subscription, error) {
|
||||
return nil, nil
|
||||
func (s MongoDBStorage) GetSubscriber(subscriber string) ([]Subscription, error) {
|
||||
collection := s.Client.Database(s.DbName).Collection(s.Collections["events"])
|
||||
subscriptions := []Subscription{}
|
||||
|
||||
var cur *mongo.Cursor
|
||||
// findOptions := options.Find()
|
||||
|
||||
// cur, err := collection.Find(context.TODO(), bson.M{"subscriptions": subscriber}, findOptions)
|
||||
|
||||
cur, err := collection.Find(context.TODO(), bson.M{"subscriptions": bson.M{"$elemMatch": bson.M{"subscriber": subscriber}}})
|
||||
if err != nil {
|
||||
return subscriptions, err
|
||||
}
|
||||
for cur.Next(context.Background()) {
|
||||
var event Event
|
||||
if err := cur.Decode(&event); err != nil {
|
||||
return subscriptions, err
|
||||
}
|
||||
for i := range event.Subscriptions {
|
||||
if event.Subscriptions[i].Subscriber == subscriber {
|
||||
subscriptions = append(subscriptions, event.Subscriptions[i])
|
||||
}
|
||||
}
|
||||
}
|
||||
fmt.Println(subscriptions)
|
||||
return subscriptions, nil
|
||||
//return nil, nil
|
||||
// if err != nil {
|
||||
// return subscriptions, err
|
||||
// }
|
||||
|
||||
// for cur.Next(context.TODO()) {
|
||||
// var event Event
|
||||
// var elem bson.M
|
||||
|
||||
// if err := cur.Decode(&elem); err != nil {
|
||||
// return subscriptions, err
|
||||
// }
|
||||
// for i := range event.Subscriptions {
|
||||
// if event.Subscriptions[i].Subscriber == subscriber {
|
||||
// subscriptions = append(subscriptions, event.Subscriptions[i])
|
||||
// }
|
||||
// }
|
||||
// // bsonBytes, _ := bson.Marshal(elem)
|
||||
// // bson.Unmarshal(bsonBytes, &event)
|
||||
|
||||
// // subscriptions = append(subscriptions, event.Subscriptions[1])
|
||||
|
||||
// }
|
||||
|
||||
// return subscriptions, nil
|
||||
}
|
||||
|
||||
func (psql MongoDBStorage) GetSubscriptionByUser(subscriber string) ([]Subscription, error) {
|
||||
return nil, nil
|
||||
func (s MongoDBStorage) GetSubscriptionByUser(subscriber string) ([]Subscription, error) {
|
||||
events, err := s.GetSubscriber(subscriber)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
fmt.Println(events)
|
||||
return events, nil
|
||||
//return nil, nil
|
||||
}
|
||||
|
||||
// [{32b91cca-da17-41ce-83fa-515a17a90fcf subscription id dans event
|
||||
|
||||
// ca7f0a47-59d3-4bb8-ab12-756017d5ec9b id benef
|
||||
|
||||
// [] 2024-07-23 12:53:45.409 +0000 UTC
|
||||
|
||||
// map[subscribed_by:map[group:map[id:483280d0-db2d-4f06-b361-02e4be5012d2 name:COOPGO]
|
||||
|
||||
// user:map[display_name:Soukaina lafdili
|
||||
|
||||
// email:soukaina.lafdili@coopgo.fr
|
||||
|
||||
// id:979888c6-656f-4af7-b7a4-97a02a3cc13d]]]}]
|
||||
|
||||
// mongo: no documents in result
|
||||
|
|
|
@ -13,6 +13,7 @@ type Storage interface {
|
|||
AddSubscription(eventid string, subscription Subscription) error
|
||||
UpdateSubscription(eventid string, subscriber string, deletesubscription Subscription) error
|
||||
UpdateEvent(Event) error
|
||||
GetSubscriber(subscriber string) ([]Subscription, error)
|
||||
GetSubscriptionByUser(subscriber string) ([]Subscription, error)
|
||||
}
|
||||
type StorageImpl struct {
|
||||
|
|
Loading…
Reference in New Issue