package ossops

import (
   "github.com/aliyun/aliyun-oss-go-sdk/oss"
)

var EndPoint string
var AccessKeyId string
var AccessKeySecret string

func init() {
   EndPoint = ""
   AccessKeyId = ""
   AccessKeySecret = ""
}

func UploadToOss(filename string, path string, bucketname string) (ok bool) {
   client, err := oss.New(EndPoint, AccessKeyId, AccessKeySecret)
   if err != nil {
      // HandleError(err)
      return false
   }

   bucket, err := client.Bucket("my-bucket")
   if err != nil {
      // HandleError(err)
      return false
   }

   err = bucket.UploadFile(filename, path, 500 * 1024, oss.Routines(3))
   if err != nil {
      // HandleError(err)
      return false
   }

   return true
}

func uploadHandler(writer http.ResponseWriter, request *http.Request, params httprouter.Params) {
    // ...
    ok := ossops.UploadToOss("/videos/"+fn, uri, "daker-wang-video"); if !ok {
      fmt.Println("上传到云OSS失败", err)
      response.SendErrorResponse(writer, defs.ErrorInternalFaults)
      return
   } else {
      //  上传成功，干掉native文件
      os.Remove(uri)
   }

   //  报告结果
   response.SendNormalResponse(writer, "upload successful", http.StatusCreated)
}

func streamHandler(writer http.ResponseWriter, request *http.Request, params httprouter.Params) {
   //  找到文件
   fn := params.ByName("vid-id")
   uri := filePath + fn
   //  打开文件 - 不是读二进制哦ioutil.ReadAll()
   file, e := os.Open(uri)
   defer file.Close()

   if e != nil {
      log.Error(e.Error())
      response.SendErrorResponse(writer, defs.ErrorInternalFaults)
      return
   }

   //  写头
   writer.Header().Set("Content-Type", "video/mp4")

   //  写流
   http.ServeContent(writer, request, "", time.Now(), file)
}

func streamHandler(writer http.ResponseWriter, request *http.Request, params httprouter.Params) {
   filename := "/videos/" + params.ByName("vid-id")
   bucket := "daker-wang-video.oss-cn-beijing-internal.aliyuncs.com"
   uri := bucket + filename

   log.Info("☁️转发到OSS服务器 %s", filename)
   
   http.Redirect(writer, request, uri, http.StatusMovedPermanently)
}

package config

import (
   "os"
   "encoding/json"
)

type Configuration struct {
   LBAddress string `json:"lb_address"`
   OSSAddress string `json:"oss_address"`
}

var configuration *Configuration

func init() {
   file, _ := os.Open("./config.json ")
   defer file.Close()

   decoder := json.NewDecoder(file)
   config := &Configuration{}

   err := decoder.Decode(config); if err != nil {
      panic(err)
   }
}

func GetLBAddress() (lbAddress string) {
   return configuration.LBAddress
}

func GetOSSAddress() (ossAddress string) {
   return configuration.OSSAddress
}

package ossops

import (
   "github.com/aliyun/aliyun-oss-go-sdk/oss"
   "azen/config" // 注意这里
)

var EndPoint string
var AccessKeyId string
var AccessKeySecret string

func init() {
   EndPoint = config.GetOSSAddress()
   AccessKeyId = ""
   AccessKeySecret = ""
}

#! /bin/bash

# 编译web、api、stream、dispatcher四个服务

cd ${GOPATH}/src/daker.wang/Azen/Go-execise/Streaming/api
env GOOS=linux GOARCH=amd64 go build -o ../../bin/api

cd ${GOPATH}/src/daker.wang/Azen/Go-execise/Streaming/dispatcher
env GOOS=linux GOARCH=amd64 go build -o ../../bin/dispatcher

cd ${GOPATH}/src/daker.wang/Azen/Go-execise/Streaming/stream
env GOOS=linux GOARCH=amd64 go build -o ../../bin/stream

cd ${GOPATH}/src/daker.wang/Azen/Go-execise/Streaming/web
env GOOS=linux GOARCH=amd64 go build -o ../../bin/web

#!/usr/bin/env bash

# 部署脚本
cp ./template ./bin/

mkdir ./bin/videos

cd bin

nohup ./api &
nohup ./dispatcher &
nohup ./stream &
nohup ./web &


echo  "🎉 deploy done~ have fun~~~"

create table comments (
 id varchar(64) not null,
 video_id varchar(64),
 author_id int(10),
 content text,
 time datetime default current_timestamp, primary key(id)
);

create table sessions (
 session_id tinytext not null,
 TTL tinytext,
 login_name text
);
alter table sessions add primary key (session_id(64));

create table users (
 id int unsigned not null auto_increment,
 login_name varchar(64),
 pwd text not null,
 unique key (login_name),
 primary key (id)
);

create table video_del_rec (
 video_id varchar(64) not null,
 primary key (video_id)
);