chore:bump go version to 1.22

fix some leaks

Author: czyt

go.mod

@@ -1,6 +1,6 @@
 module github.com/lib-x/edgetts
 
-go 1.21.6
+go 1.22.6
 
 require (
 	github.com/google/uuid v1.6.0

internal/communicate/communicate.go

@@ -116,17 +116,17 @@ func (c *Communicate) WriteStreamTo(rc io.Writer) error {
 		return err
 	}
 	audioBinaryData := make([][][]byte, c.audioDataIndex)
-	for data := range op {
-		if _, ok := data["end"]; ok {
+	for payload := range op {
+		if _, ok := payload["end"]; ok {
 			if len(audioBinaryData) == c.audioDataIndex {
 				break
 			}
 		}
-		if t, ok := data["type"]; ok && t == "audio" {
-			data := data["data"].(audioData)
+		if t, ok := payload["type"]; ok && t == "audio" {
+			data := payload["data"].(audioData)
 			audioBinaryData[data.Index] = append(audioBinaryData[data.Index], data.Data)
 		}
-		if e, ok := data["error"]; ok {
+		if e, ok := payload["error"]; ok {
 			fmt.Printf("has error err: %v\n", e)
 		}
 	}

internal/ttsTask/packTask.go

@@ -35,26 +35,17 @@ func (p *PackTask) Start(wg *sync.WaitGroup) error {
 	defer wg.Done()
 	for _, entry := range p.PackEntries {
 		// for zip file, the entry should be written after creation.
-		opt := p.CommunicateOpt
-		if entry.EntryCommunicateOpt != nil {
-			opt = entry.EntryCommunicateOpt
-
-		}
-		c, err := communicate.NewCommunicate(entry.Text, opt)
-		if err != nil {
-			log.Printf("create communicate error:%v \r\n", err)
+		if err := p.processPackEntry(entry); err != nil {
 			continue
 		}
-		entryWriter, err := p.PackEntryCreator(entry.EntryName)
-		err = c.WriteStreamTo(entryWriter)
-		if err != nil {
-			log.Printf("write data to entry writer error:%v \r\n", err)
-			return err
-		}
 	}
 	// after all entries are written, write the meta data into a json file. this process is optional.
 	// so error is ignored.
+	p.writeMetaDataForPack()
+	return nil
+}
 
+func (p *PackTask) writeMetaDataForPack() {
 	if len(p.MetaData) > 0 {
 		for _, metaData := range p.MetaData {
 			for entryName, entryPayload := range metaData {
@@ -70,5 +61,24 @@ func (p *PackTask) Start(wg *sync.WaitGroup) error {
 			}
 		}
 	}
+}
+
+func (p *PackTask) processPackEntry(entry *PackEntry) error {
+	opt := p.CommunicateOpt
+	if entry.EntryCommunicateOpt != nil {
+		opt = entry.EntryCommunicateOpt
+	}
+	c, err := communicate.NewCommunicate(entry.Text, opt)
+	defer c.CloseOutput()
+	if err != nil {
+		log.Printf("create communicate error:%v \r\n", err)
+		return err
+	}
+	entryWriter, err := p.PackEntryCreator(entry.EntryName)
+	err = c.WriteStreamTo(entryWriter)
+	if err != nil {
+		log.Printf("write data to entry writer error:%v \r\n", err)
+		return err
+	}
 	return nil
 }

speech.go

@@ -93,6 +93,10 @@ func (s *Speech) AddPackTaskWithCustomOptions(dataEntries map[string]string, ent
 	}
 	packEntries := make([]*ttsTask.PackEntry, 0, taskCount)
 	for name, text := range dataEntries {
+		// empty text will cause goroutine leak,ignore it
+		if text == "" {
+			continue
+		}
 		packEntry := &ttsTask.PackEntry{
 			Text:      text,
 			EntryName: name,