5 Commits

Author SHA1 Message Date
Adrian Zürcher
1d203d1d2f add json tag to model 2025-11-20 17:49:08 +01:00
Adrian Zürcher
2f539c254b minor changes 2025-11-20 17:47:41 +01:00
Adrian Zürcher
8e8a6d58aa fix add Responsible 2025-11-20 16:09:56 +01:00
Adrian Zürcher
3b804ff8d1 add new decrypt encrypt function to member 2025-11-20 15:17:44 +01:00
Adrian Zürcher
11b9c61113 new model 2025-11-20 10:43:49 +01:00
6 changed files with 206 additions and 148 deletions

View File

@@ -24,86 +24,21 @@ func (dh *DatabaseHandler) AddNewMember(members ...models.Member) error {
return fmt.Errorf("member %s %s %s exists already", member.FirstName, member.LastName, member.Birthday) return fmt.Errorf("member %s %s %s exists already", member.FirstName, member.LastName, member.Birthday)
} }
encFirstName, err := crypto.Encrypt(member.FirstName, dh.token)
if err != nil {
return err
}
encLastName, err := crypto.Encrypt(member.LastName, dh.token)
if err != nil {
return err
}
//check correct birtday format //check correct birtday format
if member.Birthday != "" && !utils.IsValidBirthday(member.Birthday) { if member.Birthday != "" && !utils.IsValidBirthday(member.Birthday) {
return errors.New("incorrect birthday format") return errors.New("incorrect birthday format")
} }
encBirthday, err := crypto.Encrypt(member.Birthday, dh.token)
if err != nil {
return err
}
encAddress, err := crypto.Encrypt(member.Address, dh.token)
if err != nil {
return err
}
encZip, err := crypto.Encrypt(member.Zip, dh.token)
if err != nil {
return err
}
encTown, err := crypto.Encrypt(member.Town, dh.token)
if err != nil {
return err
}
encPhone, err := crypto.Encrypt(member.Phone, dh.token)
if err != nil {
return err
}
//check correct email format //check correct email format
if member.Email != "" && !utils.IsValidEmail(member.Email) { if member.Email != "" && !utils.IsValidEmail(member.Email) {
return errors.New("incorrect email format") return errors.New("incorrect email format")
} }
encEmail, err := crypto.Encrypt(member.Email, dh.token)
if err != nil {
return err
}
now := utils.GetCurrentTime(dh.timeLocation) now := utils.GetCurrentTime(dh.timeLocation)
encFirstVisit, err := crypto.Encrypt(now, dh.token) member.FirstVisit = now
if err != nil { member.LastVisit = now
return err
}
encLastVisit, err := crypto.Encrypt(now, dh.token) member.Encrypt(dh.token)
if err != nil {
return err
}
encComment, err := crypto.Encrypt(member.Comment, dh.token)
if err != nil {
return err
}
member.FirstNameHash = dh.hashField(member.FirstName)
member.FirstName = encFirstName
member.LastNameHash = dh.hashField(member.LastName)
member.LastName = encLastName
member.BirthdayHash = dh.hashField(member.Birthday)
member.Birthday = encBirthday
member.Address = encAddress
member.Zip = encZip
member.Town = encTown
member.Phone = encPhone
member.Email = encEmail
member.FirstVisit = encFirstVisit
member.LastVisit = encLastVisit
member.Comment = encComment
err = dh.database.AddNewColum(&member) err = dh.database.AddNewColum(&member)
if err != nil { if err != nil {
@@ -137,81 +72,8 @@ func (dh *DatabaseHandler) GetMember(id uint) (members []models.Member, err erro
} }
for i := range members { for i := range members {
if members[i].FirstName != "" { if err := members[i].Decrypt(dh.token); err != nil {
members[i].FirstName, err = crypto.Decrypt(members[i].FirstName, dh.token) return members, err
if err != nil {
return
}
}
if members[i].LastName != "" {
members[i].LastName, err = crypto.Decrypt(members[i].LastName, dh.token)
if err != nil {
return
}
}
if members[i].Birthday != "" {
members[i].Birthday, err = crypto.Decrypt(members[i].Birthday, dh.token)
if err != nil {
return
}
}
if members[i].Address != "" {
members[i].Address, err = crypto.Decrypt(members[i].Address, dh.token)
if err != nil {
return
}
}
if members[i].Zip != "" {
members[i].Zip, err = crypto.Decrypt(members[i].Zip, dh.token)
if err != nil {
return
}
}
if members[i].Town != "" {
members[i].Town, err = crypto.Decrypt(members[i].Town, dh.token)
if err != nil {
return
}
}
if members[i].Phone != "" {
members[i].Phone, err = crypto.Decrypt(members[i].Phone, dh.token)
if err != nil {
return
}
}
if members[i].Email != "" {
members[i].Email, err = crypto.Decrypt(members[i].Email, dh.token)
if err != nil {
return
}
}
if members[i].FirstVisit != "" {
members[i].FirstVisit, err = crypto.Decrypt(members[i].FirstVisit, dh.token)
if err != nil {
return
}
}
if members[i].LastVisit != "" {
members[i].LastVisit, err = crypto.Decrypt(members[i].LastVisit, dh.token)
if err != nil {
return
}
}
if members[i].Comment != "" {
members[i].Comment, err = crypto.Decrypt(members[i].Comment, dh.token)
if err != nil {
return
}
} }
} }
return return

View File

@@ -2,6 +2,7 @@ package handlers
import ( import (
"errors" "errors"
"fmt"
"gitea.tecamino.com/paadi/memberDB/models" "gitea.tecamino.com/paadi/memberDB/models"
) )
@@ -11,12 +12,33 @@ func (dh *DatabaseHandler) AddNewResponsible(responsibles ...models.Responsible)
return errors.New("database not opened") return errors.New("database not opened")
} }
for i := range responsibles { next:
if !dh.database.Exists(&models.Member{}, "", "id", 25, false) { for _, r := range responsibles {
continue if r.MemberId == 0 && r.Id != 0 {
r.MemberId = r.Id
r.Id = 0
} }
err := dh.database.AddNewColum(&responsibles[i]) //check if member exists
if !dh.database.Exists(&models.Member{}, "", "id", &r.MemberId, false) {
continue
}
// check if already exists
var oldResponsibles models.Responsibles
err := dh.database.GetById(&oldResponsibles, "Member", 0)
if err != nil {
return err
}
for _, oldR := range oldResponsibles {
if oldR.Member == nil {
continue
} else if oldR.Member.Id == int(r.MemberId) {
continue next
}
}
err = dh.database.AddNewColum(&r)
if err != nil { if err != nil {
return err return err
} }
@@ -31,6 +53,13 @@ func (dh *DatabaseHandler) GetResponsible(id uint) (responsibles models.Responsi
} }
err = dh.database.GetById(&responsibles, "Member", id) err = dh.database.GetById(&responsibles, "Member", id)
for i := range responsibles {
err := responsibles[i].Member.Decrypt(dh.token)
if err != nil {
return responsibles, err
}
}
return return
} }
@@ -42,5 +71,6 @@ func (dh *DatabaseHandler) DeleteResponsible(ids ...uint) error {
if len(ids) == 0 { if len(ids) == 0 {
return errors.New("no ids given to be deleted") return errors.New("no ids given to be deleted")
} }
fmt.Println(123, ids)
return dh.database.DeleteById(&models.Responsible{}, "", ids...) return dh.database.DeleteById(&models.Responsible{}, "", ids...)
} }

View File

@@ -5,5 +5,5 @@ type Event struct {
Name string `gorm:"column:name" json:"name"` Name string `gorm:"column:name" json:"name"`
Date string `gorm:"column:date" json:"date"` Date string `gorm:"column:date" json:"date"`
Day string `gorm:"column:day" json:"day"` Day string `gorm:"column:day" json:"day"`
Attendees []*Member `gorm:"many2many:member_events;"` Attendees []*Member `gorm:"many2many:member_events;" json:"attendees"`
} }

View File

@@ -1,5 +1,10 @@
package models package models
import (
"gitea.tecamino.com/paadi/memberDB/crypto"
"gitea.tecamino.com/paadi/memberDB/utils"
)
type Member struct { type Member struct {
Id int `gorm:"primaryKey" json:"id,omitempty"` Id int `gorm:"primaryKey" json:"id,omitempty"`
FirstName string `gorm:"column:firstName" json:"firstName,omitempty"` FirstName string `gorm:"column:firstName" json:"firstName,omitempty"`
@@ -22,3 +27,146 @@ type Member struct {
Comment string `gorm:"column:comment" json:"comment,omitempty"` Comment string `gorm:"column:comment" json:"comment,omitempty"`
Events []*Event `gorm:"many2many:member_events;" ` Events []*Event `gorm:"many2many:member_events;" `
} }
func (m *Member) Encrypt(token []byte) (err error) {
m.FirstNameHash = utils.HashField(m.FirstName, token)
m.FirstName, err = crypto.Encrypt(m.FirstName, token)
if err != nil {
return
}
m.LastNameHash = utils.HashField(m.LastName, token)
m.LastName, err = crypto.Encrypt(m.LastName, token)
if err != nil {
return
}
m.BirthdayHash = utils.HashField(m.Birthday, token)
m.Birthday, err = crypto.Encrypt(m.Birthday, token)
if err != nil {
return
}
m.Address, err = crypto.Encrypt(m.Address, token)
if err != nil {
return
}
m.Zip, err = crypto.Encrypt(m.Zip, token)
if err != nil {
return
}
m.Town, err = crypto.Encrypt(m.Town, token)
if err != nil {
return
}
m.Phone, err = crypto.Encrypt(m.Phone, token)
if err != nil {
return
}
m.Email, err = crypto.Encrypt(m.Email, token)
if err != nil {
return
}
m.FirstVisit, err = crypto.Encrypt(m.FirstVisit, token)
if err != nil {
return
}
m.LastVisit, err = crypto.Encrypt(m.LastVisit, token)
if err != nil {
return
}
m.Comment, err = crypto.Encrypt(m.Comment, token)
if err != nil {
return
}
return
}
func (m *Member) Decrypt(token []byte) (err error) {
if m.FirstName != "" {
m.FirstName, err = crypto.Decrypt(m.FirstName, token)
if err != nil {
return
}
}
if m.LastName != "" {
m.LastName, err = crypto.Decrypt(m.LastName, token)
if err != nil {
return
}
}
if m.Birthday != "" {
m.Birthday, err = crypto.Decrypt(m.Birthday, token)
if err != nil {
return
}
}
if m.Address != "" {
m.Address, err = crypto.Decrypt(m.Address, token)
if err != nil {
return
}
}
if m.Zip != "" {
m.Zip, err = crypto.Decrypt(m.Zip, token)
if err != nil {
return
}
}
if m.Town != "" {
m.Town, err = crypto.Decrypt(m.Town, token)
if err != nil {
return
}
}
if m.Phone != "" {
m.Phone, err = crypto.Decrypt(m.Phone, token)
if err != nil {
return
}
}
if m.Email != "" {
m.Email, err = crypto.Decrypt(m.Email, token)
if err != nil {
return
}
}
if m.FirstVisit != "" {
m.FirstVisit, err = crypto.Decrypt(m.FirstVisit, token)
if err != nil {
return
}
}
if m.LastVisit != "" {
m.LastVisit, err = crypto.Decrypt(m.LastVisit, token)
if err != nil {
return
}
}
if m.Comment != "" {
m.Comment, err = crypto.Decrypt(m.Comment, token)
if err != nil {
return
}
}
return
}

9
models/responsible.go Normal file
View File

@@ -0,0 +1,9 @@
package models
type Responsible struct {
Id uint `gorm:"primaryKey" json:"id"`
MemberId uint
Member *Member `gorm:"foreignKey:MemberId;constraint:OnDelete:CASCADE;" json:"member"`
}
type Responsibles []Responsible

View File

@@ -1,6 +1,9 @@
package utils package utils
import ( import (
"crypto/hmac"
"crypto/sha256"
"encoding/hex"
"fmt" "fmt"
"net/mail" "net/mail"
"time" "time"
@@ -34,3 +37,9 @@ func GetCurrentTime(loc *time.Location) string {
func GetCurrentDay(loc *time.Location) string { func GetCurrentDay(loc *time.Location) string {
return fmt.Sprint(time.Now().In(loc).Weekday()) return fmt.Sprint(time.Now().In(loc).Weekday())
} }
func HashField(field string, token []byte) string {
h := hmac.New(sha256.New, token)
h.Write([]byte(field))
return hex.EncodeToString(h.Sum(nil))
}