DEV Community: Perm Chao

Try to stream video part 1

Perm Chao — Tue, 02 Jun 2026 08:50:04 +0000

For path 1, I want to try basic thing to streaming video on internet. Let begin with using ffmpeg + video.js

Backend service

main.go

func main() {
    fileServer := http.FileServer(http.Dir("./videos"))


    http.Handle("/upload", http.HandlerFunc(uploadHandler))
    http.Handle("/stream/", http.StripPrefix("/stream/", fileServer))



    err := http.ListenAndServe(":8080", func(next http.Handler) http.Handler {
        return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            w.Header().Set("Access-Control-Allow-Origin", "*")
            w.Header().Set("Access-Control-Allow-Methods", "GET, OPTIONS")
            w.Header().Set("Access-Control-Allow-Headers", "Content-Type")
            if r.Method == "OPTIONS" {
                w.WriteHeader(http.StatusOK)
                return
            }
            next.ServeHTTP(w, r)
        })
    }(http.DefaultServeMux))
    if err != nil {
        log.Fatal(err)
    }
}

func uploadHandler(w http.ResponseWriter, r *http.Request) {
    if r.Method != http.MethodPost {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    r.Body = http.MaxBytesReader(w, r.Body, 2<<30)

    file, header, err := r.FormFile("video")
    if err != nil {
        http.Error(w, fmt.Sprintf("Error retrieving file: %v", err), http.StatusBadRequest)
        return
    }
    defer file.Close()

    log.Printf("📥 กำลังรับไฟล์: %s (ขนาด: %d bytes)", header.Filename, header.Size)

    uploadDir := "./raw_videos"
    if err := os.MkdirAll(uploadDir, os.ModePerm); err != nil {
        http.Error(w, "Unable to create directory", http.StatusInternalServerError)
        return
    }

    destPath := filepath.Join(uploadDir, header.Filename)
    destFile, err := os.Create(destPath)
    if err != nil {
        http.Error(w, "Unable to create file on server", http.StatusInternalServerError)
        return
    }
    defer destFile.Close()

    _, err = io.Copy(destFile, file)
    if err != nil {
        http.Error(w, fmt.Sprintf("Error saving file: %v", err), http.StatusInternalServerError)
        return
    }

    log.Printf("✅ อัปโหลดสำเร็จ: %s ถูกเซฟไว้ที่ %s", header.Filename, destPath)

    seq.Add(1)
    id := seq.Load()

    // ** --------------------- Focus here --------------------- **
    go func(id int64, path string) {
        if e := tsToHLS(destPath, "./videos"); e != nil {
            log.Panicln(e)
        }
    }(id, destPath)

    w.WriteHeader(http.StatusOK)
    w.Write(fmt.Appendf(nil, "Upload successful: %s", header.Filename))
}

func tsToHLS(i, o string) error {
    plPath := filepath.Join(o, "playlist.m3u8")
    sPath := filepath.Join(o, "video_%03d.ts")
    cmd := exec.Command("ffmpeg",
        "-i", i,
        "-vf", "scale=854:-2",
        "-crf", "26",
        "-b:v", "1000k",
        "-maxrate", "1000k",
        "-bufsize", "2000k",
        "-codec:v", "libx264",
        "-codec:a", "aac",
        "-f", "hls",
        "-hls_time", "10",
        "-hls_list_size", "0",
        "-hls_segment_filename", sPath,
        plPath,
    )

    log.Printf("⏳ กำลังเริ่มแปลงไฟล์: %s ...", i)
    output, err := cmd.CombinedOutput()
    if err != nil {
        return fmt.Errorf("FFmpeg error: %v, output: %s", err, string(output))
    }

    log.Println("✅ แปลงไฟล์เป็น HLS สำเร็จแล้ว!")
    return nil
}

ตารางสรุปพารามิเตอร์ FFmpeg สำหรับระบบ Streaming

พารามิเตอร์ (Args)	หน้าที่และความหมาย	ตัวอย่างการใช้งาน	ประโยชน์ที่มีต่อระบบ Local Netflix
`-i`	Input: ระบุพาธหรือชื่อไฟล์วิดีโอต้นฉบับที่ต้องการนำมาประมวลผล	`-i input.mp4`	บอกให้ FFmpeg รู้ว่าจะเอาหนังเรื่องไหนมาจัดการ
`-vf`	Video Filter: ใช้จัดการตัวเนื้อภาพ ในที่นี้เราใช้ฟิลเตอร์ `scale` เพื่อย่อ/ขยายขนาดภาพ	`-vf "scale=1280:-2"`	ลดความละเอียดภาพ (เช่น เหลือ 720p) ทำให้ไฟล์เล็กลงอย่างเห็นได้ชัด
`-crf`	Constant Rate Factor: คุมคุณภาพของภาพภาพรวม (ค่าเลขยิ่งเยอะ ไฟล์ยิ่งเล็ก แต่ภาพจะแตก)	`-crf 26`	ช่วยบีบอัดไฟล์ให้เล็กลงโดยรักษาความชัดให้อยู่ในเกณฑ์ที่สายตาคนมองว่าสวย
`-b:v`	Video Bitrate: กำหนดอัตราการส่งข้อมูลของภาพวิดีโอต่อวินาที	`-b:v 2000k`	ควบคุมไม่ให้บิตเรตพุ่งสูงเกินไป ป้องกันการกระตุกของ WiFi ในบ้าน
`-maxrate`	Maximum Bitrate: กำหนดเพดานบิตเรตสูงสุดไม่ให้เกินค่านี้เด็ดขาดในฉากที่เคลื่อนไหวเร็ว	`-maxrate 2000k`	ป้องกันไม่ให้ฉากแอคชั่นกินแบนด์วิดท์เน็ตเวิร์กสูงเกินไป
`-bufsize`	Buffer Size: กำหนดขนาดของถังพักข้อมูลที่ FFmpeg จะใช้วิเคราะห์เพื่อคุมบิตเรต	`-bufsize 4000k`	ช่วยให้การคำนวณบิตเรตไหลลื่นและคงที่นิ่งขึ้น
`-codec:v` (หรือ `-c:v`)	Video Codec: เลือกตัวถอดรหัส/เข้ารหัสภาพวิดีโอ	`-codec:v libx264`	แปลงให้เป็นฟอร์แมต H.264 ซึ่งเป็นมาตรฐานที่ Browser ทุกตัวเปิดดูได้ชัวร์
`-codec:a` (หรือ `-c:a`)	Audio Codec: เลือกตัวถอดรหัส/เข้ารหัสระบบเสียง	`-codec:a aac`	แปลงระบบเสียงเป็น AAC ซึ่งเป็นที่นิยมและรองรับบนหน้าเว็บอย่างสมบูรณ์
`-b:a`	Audio Bitrate: กำหนดอัตราการส่งข้อมูลของเสียงต่อวินาที	`-b:a 128k`	บีบอัดไฟล์เสียงให้เล็กลง แต่ยังคงความชัดเจนของเสียงพูดและเพลง
`-f`	Format: ระบุรูปแบบปลายทางของไฟล์ผลลัพธ์	`-f hls`	สั่งให้ส่งเอาต์พุตออกมาเป็นระบบ HLS (HTTP Live Streaming)
`-hls_time`	HLS Segment Duration: กำหนดความยาว (วินาที) ของไฟล์วิดีโอย่อยแต่ละชิ้น	`-hls_time 10`	สั่งให้หั่นวิดีโอซอยออกมาเป็นชิ้นละ 10 วินาที (ไฟล์ตระกูล `.ts`)
`-hls_list_size`	Playlist Window Size: กำหนดจำนวนไฟล์ย่อยที่จะแสดงในสารบัญ (0 หมายถึงให้ใส่ทั้งหมด)	`-hls_list_size 0`	บังคับให้ไฟล์ `.m3u8` เก็บรายชื่อวิดีโอตั้งแต่ต้นจนจบเรื่อง (ถ้าตั้งเป็น 5 จะดูได้แค่ 5 ชิ้นล่าสุดเหมือนไลฟ์สด)
`-hls_segment_filename`	Segment Naming: กำหนดรูปแบบการตั้งชื่อและพาธของไฟล์วิดีโอย่อยที่ถูกหั่น	`-hls_segment_filename "video_%03d.ts"`	ได้ไฟล์ชื่อเรียงตามลำดับ เช่น `video_001.ts`, `video_002.ts` เพื่อให้ไล่ลำดับได้ถูกต้อง

Implement semaphore in golang by buffered channel

Perm Chao — Tue, 10 Jun 2025 15:06:34 +0000

Getting started

1) make buffered channel

sem := make(chan int, 10)

2) in synchronous process, send some variable to buffered channel (this step called acquire)

sem <- i

3) in asynchronous process, release variable from buffered channel (this step called release)

<- sem

Result from log

start   process [9]
start   process [0]
start   process [7]
start   process [6]
start   process [3]
start   process [2]
start   process [4]
start   process [8]
start   process [1]
start   process [5] <- 10 processes start concurrency
end     process [0]      0.0001 seconds
start   process [10] <- process 10 start after process 0 end
end     process [2]      4.0014 seconds
end     process [1]      4.0012 seconds
start   process [12]
start   process [11] <- process 11, 12 start after process 1, 2 end
end     process [3]      5.0011 seconds
start   process [13]
end     process [4]      0.0001 seconds
start   process [14]
end     process [5]      6.0014 seconds
start   process [15]
end     process [6]      1.0011 seconds
start   process [16]
end     process [7]      8.0013 seconds
start   process [17]
...

Remark

Standard package
golang.org/x/sync/semaphore

Code

package main

import (
    "fmt"
    "math/rand"
    "time"
)

const (
    MAX_CONCURRENT     = 10   // Allow max concurrent
    TOTAL_PROCESSES    = 1000 // Total loop count
    MAX_RANDOM_SECONDS = 20
)

func main() {
    sem := make(chan int, MAX_CONCURRENT)
    for i := range TOTAL_PROCESSES {
        sem <- i // *** send i to buffered channel. If channel sem full, it blocked for loop.
        go func(i int) {
            start := time.Now()
            fmt.Printf("start\tprocess\t[%d]\n", i)
            defer func() {
                // <- sem will release a value, so sem channel will available for next value
                fmt.Printf("end\tprocess\t[%d]\t %.4f seconds\n", <-sem, time.Since(start).Seconds())
            }()
            iv := rand.Intn(MAX_RANDOM_SECONDS) * int(time.Second)
            time.Sleep(time.Duration(iv))
        }(i)
    }
}

start   process [0]
start   process [9]
start   process [5]
start   process [6]
start   process [7]
start   process [8]
start   process [2]
start   process [1]
start   process [3]
start   process [4]
start   process [10]
end     process [0]      3.0013 seconds
start   process [11]
end     process [1]      2.0012 seconds
start   process [12]
end     process [2]      6.0012 seconds
end     process [3]      9.0012 seconds
start   process [13]
end     process [4]      5.0008 seconds
start   process [14]
end     process [5]      12.0012 seconds
end     process [6]      12.0012 seconds
start   process [16]
start   process [15]
start   process [17]
end     process [7]      14.0012 seconds
end     process [8]      16.0012 seconds
end     process [9]      16.0012 seconds
start   process [19]
end     process [10]     0.0001 seconds
start   process [20]
start   process [18]
end     process [11]     17.0012 seconds
start   process [21]
end     process [12]     18.0002 seconds
start   process [22]
end     process [14]     8.0012 seconds
end     process [13]     4.0010 seconds
start   process [24]
start   process [23]
end     process [15]     15.0011 seconds
start   process [25]
start   process [26]
end     process [16]     13.0011 seconds
end     process [17]     15.0005 seconds
start   process [27]
end     process [18]     0.0000 seconds
start   process [28]
end     process [19]     5.0010 seconds
end     process [20]     4.0011 seconds
start   process [29]
start   process [30]
end     process [21]     2.0005 seconds
end     process [22]     12.0011 seconds
start   process [31]
start   process [32]
end     process [23]     6.0002 seconds
start   process [33]
end     process [24]     1.0002 seconds
start   process [34]
end     process [25]     9.0011 seconds
start   process [35]
end     process [26]     1.0002 seconds
start   process [36]
end     process [27]     12.0011 seconds
start   process [37]
end     process [28]     3.0007 seconds
start   process [38]
end     process [29]     13.0011 seconds
start   process [39]
end     process [30]     19.0012 seconds
start   process [40]
end     process [31]     8.0010 seconds
start   process [41]
end     process [32]     8.0011 seconds
start   process [42]
end     process [33]     8.0001 seconds
start   process [43]
end     process [34]     11.0010 seconds
end     process [35]     13.0001 seconds
start   process [45]
start   process [44]
end     process [36]     2.0009 seconds
start   process [46]
end     process [37]     1.0002 seconds
start   process [47]
end     process [38]     8.0011 seconds
start   process [48]
end     process [39]     2.0011 seconds
start   process [49]
end     process [40]     4.0011 seconds
start   process [50]
end     process [41]     6.0011 seconds
start   process [51]
start   process [52]
end     process [42]     19.0011 seconds
end     process [43]     15.0011 seconds
start   process [53]
end     process [44]     0.0000 seconds
start   process [54]
end     process [45]     17.0004 seconds
start   process [55]
end     process [46]     19.0006 seconds
start   process [56]
start   process [57]
end     process [47]     15.0011 seconds
end     process [48]     3.0011 seconds
start   process [58]
end     process [49]     17.0011 seconds
start   process [59]
end     process [50]     18.0011 seconds
start   process [60]
end     process [51]     0.0001 seconds
start   process [61]
end     process [52]     11.0001 seconds
end     process [53]     18.0004 seconds
start   process [63]
start   process [62]
end     process [54]     19.0011 seconds
start   process [64]
start   process [65]
end     process [55]     19.0002 seconds
end     process [56]     16.0006 seconds
start   process [66]
end     process [57]     11.0001 seconds
start   process [67]
end     process [58]     12.0001 seconds
start   process [68]
end     process [59]     18.0011 seconds
start   process [69]
end     process [60]     9.0002 seconds
start   process [70]
end     process [61]     6.0011 seconds
start   process [71]
end     process [63]     7.0006 seconds
end     process [62]     8.0011 seconds
start   process [73]
start   process [72]
end     process [64]     13.0011 seconds
start   process [74]
end     process [65]     15.0006 seconds
start   process [75]
end     process [66]     17.0001 seconds
start   process [76]
end     process [67]     3.0002 seconds
start   process [77]
end     process [68]     15.0011 seconds
start   process [78]
start   process [79]
end     process [69]     14.0007 seconds
end     process [70]     6.0006 seconds
end     process [71]     11.0012 seconds
start   process [81]
start   process [80]
end     process [72]     11.0011 seconds
start   process [82]
end     process [73]     4.0003 seconds
start   process [83]
end     process [74]     11.0008 seconds
end     process [75]     15.0011 seconds
start   process [85]
start   process [84]
end     process [76]     2.0011 seconds
start   process [86]
end     process [77]     6.0009 seconds
start   process [87]
end     process [78]     1.0011 seconds
start   process [88]
end     process [79]     6.0009 seconds
start   process [89]
end     process [80]     6.0011 seconds
end     process [81]     11.0008 seconds
start   process [91]
start   process [90]
start   process [92]
end     process [82]     18.0011 seconds
end     process [83]     16.0012 seconds
start   process [93]
end     process [84]     4.0002 seconds
start   process [94]
end     process [85]     9.0011 seconds
start   process [96]
start   process [95]
start   process [97]
end     process [86]     11.0003 seconds

Produce and consume Kafka message with samara and golang

Perm Chao — Sat, 07 Jun 2025 04:52:53 +0000

Declare producer
Produce message
Declare consumer
Consume each partition

Port and Adapter in Go with Uber FX

Perm Chao — Thu, 08 May 2025 10:11:27 +0000

Case

Sending email

Folder Structure

cmd/sender/main.go
internal/services/sender/sender.go
adapters/gmail/gmail.go
adapters/hotmail/hotmail.go

Steps

Create port

File: internal/services/sender/sender.go

IEmailPort will be interface for adapter

Create core business

File: internal/services/sender/sender.go

IEmailService will be interface for UberFX
EmailService will be struct of service with attribute emailPort(will be injected by UberFX)
NewEmailService is constructor

Create adapters

File: adapters/gmail/gmail.go

GmailAdapter will be interface for UberFX

File: adapters/hotmail/hotmail.go
** Hotmail like gmail, just replace gmail with hotmail **

Create program

File: cmd/sender/main.go

NewEmailAdapter function will let UberFX know that IEmailPort interface will use Gmail adapter struct
We can switch adapter to hotmail by comment out return hotmail.NewHotmailAdapter() in function NewEmailAdapter

Entgo.io - Many to Many

Perm Chao — Mon, 05 May 2025 10:46:54 +0000

Entities

1) User
2) Post

Relationship

One user can have many groups
One group can have many users

Steps

1) Generate user and post

go run -mod=mod entgo.io/ent/cmd/ent new User
go run -mod=mod entgo.io/ent/cmd/ent new Group

2) Connect user with group

func (User) Edges() []ent.Edge {
    return []ent.Edge{
        edge.To("groups", Group.Type),
    }
}

3) Connect group with user

func (Group) Edges() []ent.Edge {
    return []ent.Edge{
        edge.From("users", User.Type).Ref("groups"),
    }
}

4) Try to create user and groups

func CreateUser(client *ent.Client, ctx context.Context) {
    // Create groups
    g1, _ := client.Group.Create().SetName("Group 1").Save(ctx)
    g2, _ := client.Group.Create().SetName("Group 2").Save(ctx)

    // Create user
    u, _ := client.User.Create().SetName("PP").AddGroups(g1, g2).Save(ctx)
}

5) Get user with groups

func CreateUser(client *ent.Client, ctx context.Context) {
    ...
    userWithGroups, _ := client.User.Query().WithGroups().Where(user.NameEQ("PP")).First(ctx)
    log.Println("user with groups", userWithGroups.Edges.Groups)
}

ลองใช้งาน jaeger ครั้งแรก

Perm Chao — Mon, 05 May 2025 10:30:57 +0000

โหลด Jaeger UI มาก่อน ในที่นี้ขอเลือกลงแบบง่ายๆผ่าน docker เพื่อทดสอบเฉยๆนะครับ

docker pull jaegertracing/all-in-one

docker run -d --name jaeger -e COLLECTOR_ZIPKIN_HTTP_PORT=9411 -p 5775:5775/udp -p 6831:6831/udp -p 6832:6832/udp -p 5778:5778 -p 16686:16686 -p 14268:14268 -p 9411:9411 jaegertracing/all-in-one

ลองใช้กับ function ใน Node.js ผ่าน library opentracing

ลองใช้ Google Wire เพื่อทำ Dependency Injection ใน Go

Perm Chao — Sat, 06 Apr 2024 16:15:47 +0000

Wire is a code generation tool that automates connecting components using dependency injection

ลองใช้ Wire กับ Project API Todo แบบง่ายๆ

เครื่องมือที่ใช้

golang
go fiber
postgres

ขั้นตอน

เริ่มจากสร้างโปรเจคขึ้นมา 1 โปรเจคโดยมีไฟล์ในโฟรเดอร์ดังนี้

go.mod
cmd
- webservice
- main.go
- wire.go
controllers
- todo_controller.go
services
- config
- env.go
- db
- gorm.go
- server
- fiber.go

โฟกัสที่ file cmd/webservice/main.go สร้าง struct ขึ้นมาหนึ่งตัวและ function ที่ทำหน้าที่สร้าง struct ตัวนั้นเสมือนเป็น constructor

// vvvvvvvv สนใจ struct ตัวนี้ vvvvvvvv
type WebService struct {
 ENVConfig *config.ENVConfig
 DB        *gorm.DB
 TodoController *controllers.TodoController
}

// vvvvvvvv สนใจ function ตัวนี้ vvvvvvvv
func NewWebService(envConfig *config.ENVConfig, db *gorm.DB, todoController *controllers.TodoController) *WebService {
 return &WebService{
  DB: db,
  ENVConfig: envConfig,
  TodoController: todoController,
 }
}

func main() {
 // ยังไม่ต้องสนใจตรงนี้
}

ไปที่ file cmd/webservice/wire.go จะเห็นว่าที่ wire.Build(...) ใน ... จะต้องมี function ที่ return struct ที่เราสนใจจะใช้งานใน struct Webservice

// vvvvvvvv ต้องใส่นะ vvvvvvvv
//go:build wireinject
// +build wireinject

func InitWebservice() *Webservice {
    wire.Build(NewWebService, config.NewENVConfig, db.NewDB, controllers.NewTodoController)
    return &Webservice{}
}

กลับมาที่ file cmd/webservice/main.go แล้ว run คำสั่งใน terminal run คำสั่ง wire แล้วมันจะสร้าง file มาให้อันนึงชื่อ wire_gen.go ซึ่งในนั้นจะมี function InitWebservice มาให้ในแบบที่ inject ตัว dependencies ทั้งหมดที่จำเป็นมาให้แล้ว

func main() {
 webservice := InitWebservice()
}

ซึ่งถ้าต้องการเพิ่ม dependencies ต้องเพิ่ม 2 ที่
function New....(..., dependency ที่เราอยากเพิ่ม *DependencyStruct)
wire.Build(...., NewDependencyFn ที่ return dependency นั้นๆ) แล้ว wire จะไปหา dependency เหล่านั้นมาใส่ให้เราเอง ความ

ความรู้สึกหลังใช้

รู้สึกว่าไม่ค่อยจำเป็นต้องใช้มันเท่าไหร่ 555

Try using websocket with Go Fiber for the first time

Perm Chao — Sat, 08 Oct 2022 18:19:22 +0000

Objective

I want to implement simple chatroom with websocket (in go fiber middleware)

Step (code in every step will be in `main.go`)

1) make channels for receive commands chan and map channels and user in rooms

2) write function to receive command from connection

3) set endpoint to make connection

NestJS Micro-services 101 Part 1 - Try to communicate btw two services

Perm Chao — Sat, 01 Oct 2022 16:50:05 +0000

I try to learn NestJS Framework to make micro-services

Objective in Part 1

send simple message from one service to another service

// Project 1 api-gateway
nest new api-gateway

// Project ที่ 2 user-service
nest new user

User Request (http://localhost:3000) -> API Gateway -> User

Difference btw bootstrap in api-gateway and user

api-gateway main.ts

user main.ts

api-gateway service will know user service by register in api-gateway module

so you can declare user service proxy in constructor to send data into it, by
hello is event pattern

user service controller will receive event pattern name hello by use EventPattern decorator

So, this is response

Full code https://github.com/mossnana/nestjs/tree/microservices

Interface and DB in golang

Perm Chao — Sun, 06 Mar 2022 09:04:19 +0000

As implement hexagonal pattern (Ports and adapters pattern), our code should separate to three sections

API (Application Programming Interface) such your inbound (Gin, Echo, Fiber ...), Serialization or something else
Domain, Entity or something else that make your app unique
SPI (Service Programming Interface) such as external service, DB, DAO (Data Access Object) or something else

Example with below code, This will show relation with My Entity (Todo) and SPI(Database Insert)

Entity -> Todo struct
Port -> TodoHandler
Adapters -> todoAdapter interface, MySQLDB and MongoDB struct

package main

import (
    "log"

    "go.mongodb.org/mongo-driver/mongo"
    "gorm.io/gorm"
)

type Todo struct {
    ID          string
    Title       string
    Description string
}

type todoAdapter interface {
    Create(*Todo) error
}

type TodoHandler struct {
    adapter todoAdapter
}

type MySQLDB struct {
    db *gorm.DB
}

type MongoDB struct {
    db *mongo.Collection
}

func NewTodoHandler(adapter todoAdapter) *TodoHandler {
    return &TodoHandler{adapter: adapter}
}

func (db *MySQLDB) Create(todo *Todo) error {
    log.Println("🐟 MySQL Create Interface")

    // in real example, you can comment out below code
    // err := db.db.Create(todo)
    // return err

    return nil
}

func NewMySQLDB(db *gorm.DB) *MySQLDB {
    return &MySQLDB{db: db}
}

func (db *MongoDB) Create(todo *Todo) error {
    log.Println("✅ MongoDB Create Interface")

    // in real example, you can comment out below code
    // _, err := db.db.InsertOne(context.TODO(), todo)
    // return err

    return nil
}

func NewMongoDB(db *mongo.Collection) *MongoDB {
    return &MongoDB{db: db}
}

func main() {
    var todoHandler *TodoHandler

    // Todo insert with MySQL
    mysqlAdapter := NewMySQLDB(&gorm.DB{})
    todoHandler = NewTodoHandler(mysqlAdapter)
    todoHandler.adapter.Create(&Todo{
        ID: "1", Title: "New note", Description: "Save in mysql",
    })

    // Todo insert with MongoDB
    mongoAdapter := NewMongoDB(&mongo.Collection{})
    todoHandler = NewTodoHandler(mongoAdapter)
    todoHandler.adapter.Create(&Todo{
        ID: "1", Title: "New note", Description: "Save in mongo",
    })
}

In the example, you will see two adapters should implement Create method to related with adapter interface

And result will be like this

2022/03/06 15:35:46 🐟 MySQL Create Interface
2022/03/06 15:35:46 ✅ MongoDB Create Interface

Initial API project with Go

Perm Chao — Thu, 27 Jan 2022 10:22:39 +0000

เกริ่นนำ

เนื่องจากช่วงนี้ผมได้มาเริ่มต้นโปรเจค API ด้วย Golang บ่อย
ผมเลยขอบันทึกไว้กันลืม

Stack

1) Golang
2) Go Fiber
3) Gorm
4) PostgreSQL

Steps

1) สร้าง Folder สำหรับที่อยู่ของโปรเจค

$ mkdir demo
$ cd demo

2) สร้าง go mod file

$ go mod init github.com/mossnana/demo

3) สร้าง Folders / Files ที่เก็บ source code

$ mkdir cmd
$ mkdir internal
$ mkdir pkg

** Folder **

cmd ไว้วางโฟรเดอร์ที่มีไฟล์ main.go สำหรับโปรแกรมต่าง ๆ เช่น
- server ตัว run web server
- migrator ตัว migrate db
internal ไว้ใส่ไฟล์ที่เก็บ logic ที่เกี่ยวข้องกับตัว api นี้ ที่มีความเฉพาะตัวของ api นี้
pkg ไว้เก็บไฟล์ที่ไว้ต่อกับโปรแกรมนอก เช่น function ต่อ database ๆลๆ

4) สร้าง Folders / Files ที่ไว้ run
Dockerfile

FROM golang:latest
WORKDIR /app
COPY . .

RUN go mod tidy
RUN go get github.com/githubnemo/CompileDaemon
RUN go build -o bin/migrator ./cmd/migrator

CMD CompileDaemon --build="go build -o bin/server ./cmd/server" --command="./bin/server"

CompileDaemon ใช้เป็นตัว auto restart เมื่อ code เปลี่ยน

docker-compose.yml

version: "3.5"

services:
  demo_service:
    container_name: demo_service
    build:
      context: .
      dockerfile: Dockerfile
    volumes:
      - ./:/app
    restart: always
    ports:
      - "3000:3000"
    networks:
      - demo_net
    env_file:
      - ./.env

  brij_db:
    container_name: brij_db
    image: postgres:14
    volumes:
      - "demo_db_data:/var/lib/postgresql/data"
    ports:
      - "5432:5432"
    environment:
      - POSTGRES_USER=demo
      - POSTGRES_PASSWORD=demopassword
      - POSTGRES_DB=demo
    networks:
      - demo_net

networks:
  demo_net:
    external: false

volumes:
  demo_db_data:
    external: false

Makefile

build:
    docker-compose up -d --build

start:
    docker-compose up -d

migrate:
    docker exec -it demo_service /app/bin/migrator

stop:
    docker-compose down

Project tree

.
├── cmd/
│   ├── demo/
│   │   └── main.go
│   └── migrator/
│       └── main.go
├── internal/
│   ├── model/
│   │   ├── sale.go
│   │   ├── purchase.go
│   │   └── account.go
│   ├── repository/
│   │   ├── sale.go
│   │   ├── purchase.go
│   │   └── account.go
│   ├── service/
│   │   ├── sale/
│   │   │   ├── v1/
│   │   │   │   ├── create.go
│   │   │   │   ├── read.go
│   │   │   │   ├── update.go
│   │   │   │   └── delete.go
│   │   │   └── v2/
│   │   │       ├── create.go
│   │   │       ├── read.go
│   │   │       ├── update.go
│   │   │       └── delete.go
│   │   └── ...
│   ├── handler/
│   │   └── sale/
│   │       ├── v1/
│   │       │   ├── create.go
│   │       │   ├── read.go
│   │       │   ├── update.go
│   │       │   └── delete.go
│   │       ├── v2/
│   │       │   ├── create.go
│   │       │   ├── read.go
│   │       │   ├── update.go
│   │       │   └── delete.go
│   │       └── ...
│   └── route/
│       ├── sale.go
│       ├── purchase.go
│       └── account.go
├── pkg/
│   ├── auth/
│   │   └── auth.go
│   └── gorm/
│       ├── driver.go
│       └── migrate.go
├── Dockerfile
├── docker-compose.yml
└── Makefile

การ Build

go build -o bin/{{ชื่อแอปใน main}} ./cmd/{{ชื่อแอปใน main}}

หัดใช้งาน GraphQL ด้วย Apollo Server

Perm Chao — Sat, 18 Sep 2021 02:39:24 +0000

1) เริ่มต้นการทำงานของ Apollo Server ด้วย Koa

app.ts

/*
import Koa from 'koa'
import Router from 'koa-router'
*/
// จาก lib `apollo-server-koa`
import { ApolloServer } from 'apollo-server-koa'

// ไฟล์นี้สร้างในข้อสอง
import graphqlSchema from './graphqlSchema'

/*
async function createApp(): Promise<Koa> {

 const application = new Koa()
 const router = new Router()
 */


 const graphqlServer = new ApolloServer({
  introspection: true,
  schema: graphqlSchema,
  context: ({ ctx }) => ctx
 })

 await graphqlServer.start()

 router.post("/graphql", graphqlServer.getMiddleware())
 router.get("/graphql", graphqlServer.getMiddleware())

 /*
 application.use(router.routes())
 return application

}
*/

2) กำหนด schema เริ่มต้น

schema.ts

import { GraphQLObjectType, GraphQLSchema } from 'graphql'
import GetUser from '.......'

export default new GraphQLSchema({
  query: new GraphQLObjectType({
    name: 'Query',
    fields: {
      // สามารถเพิ่มประเภทของการ Query ได้เรื่อย ๆ
      GetUser,
      .
      ..
      ...
    }
  }),
})

3) กำหนด Query GetUser

import User from '.......'

export default {
  type: User,
  resolve: async () => ({
    id: "test_id",
    name: "test_name"
  }),
}

4) กำหนด Schema User

import { GraphQLObjectType, GraphQLID, GraphQLString } from "graphql"

export const User = new GraphQLObjectType({
  name: 'User',
  fields: () => ({
    id: {
      type: GraphQLID,
    },
    name: {
      type: GraphQLString,
      resolve: async args => {
        // args จะเป็น resolve ของ query สามารถเอาไปใช้งานต่อได้
        console.log(args) // { id: 'test_id', name: 'test_name' }
        return 'finish'
      }
    }
  }),
})

DEV Community: Perm Chao

Try to stream video part 1

ตารางสรุปพารามิเตอร์ FFmpeg สำหรับระบบ Streaming

Implement semaphore in golang by buffered channel

Getting started

Result from log

Remark

Code

Produce and consume Kafka message with samara and golang

Port and Adapter in Go with Uber FX

Case

Folder Structure

Steps

Create port

Create core business

Create adapters

Create program

Entgo.io - Many to Many

Entities

Relationship

Steps

ลองใช้งาน jaeger ครั้งแรก

ลองใช้ Google Wire เพื่อทำ Dependency Injection ใน Go

เครื่องมือที่ใช้

ขั้นตอน

ความรู้สึกหลังใช้

Try using websocket with Go Fiber for the first time

Objective

Step (code in every step will be in main.go)

NestJS Micro-services 101 Part 1 - Try to communicate btw two services

Objective in Part 1

Interface and DB in golang

Initial API project with Go

เกริ่นนำ

Stack

Steps

การ Build

หัดใช้งาน GraphQL ด้วย Apollo Server

Step (code in every step will be in `main.go`)