diff --git a/srt/stream_ids.go b/srt/stream_ids.go
index 88bde45..d6548dc 100644
--- a/srt/stream_ids.go
+++ b/srt/stream_ids.go
@@ -4,15 +4,15 @@ import (
 	"os"
 	"io"
 	"strings"
+	"stream_server/transcoder"
 )
 
 func NewWriter(stream_key string) (io.WriteCloser, error) {
-	base_dir, _ := os.UserHomeDir()
-	file, err := os.Create(base_dir + "/live/" + stream_key + "/rawdump.ts")
+	transcoder_in, err := transcoder.NewTranscoder(stream_key)
 	if err != nil {
 		return nil, err
 	}
-	return file, nil
+	return transcoder_in, nil
 }
 
 func CheckStreamID(stream_id []byte) (io.WriteCloser, bool) {