catalin/sfu
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Compare commits

base: catalin:4a4a0a2149508573aeaf3c8d5e96080d42816594
Branches Tags
catalin:main
...
compare: catalin:9fd61168587466f0f5be7497ad758c40b42e51f3
Branches Tags
catalin:main

5 commits
4a4a0a2149 ... 9fd6116858

Author SHA1 Message Date
cătălin
9fd6116858
 		ci: remove staticcheck install using go install in favor of alpine's
Some checks reported errors
continuous-integration/drone/pr Build was killed
Details
continuous-integration/drone/push Build was killed
Details
continuous-integration/drone Build is passing
Details
2022-06-28 15:27:16 +02:00
cătălin
33cc395882
 		ci: fix staticcheck job by adding libc and gcc deps
Some checks reported errors
continuous-integration/drone/push Build was killed
Details
continuous-integration/drone/pr Build was killed
Details
2022-06-28 15:21:22 +02:00
cătălin
e7a9ddc460
 		ci: add staticcheck job
Some checks failed
continuous-integration/drone/push Build is failing
Details
2022-06-28 15:09:00 +02:00
cătălin
3dceae4be0
 		chore: add build badge
All checks were successful
continuous-integration/drone/push Build is passing
Details
2022-06-28 14:25:21 +02:00
cătălin
f3ea851dd8
 		ci: add docker upload job 2022-06-28 14:23:42 +02:00
5 changed files with 45 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

25
.drone.yml Normal file
View file

@ -0,0 +1,25 @@
---
kind: pipeline
type: docker
name: default
steps:
- name: staticcheck
image: golang:1.18.3-alpine3.16
commands:
- apk add --no-cache git~=2 staticcheck~=2022 gcc~=11 libc-dev~=0
- staticcheck
- name: build
image: plugins/docker
settings:
username:
from_secret: DOCKER_USERNAME
password:
from_secret: DOCKER_PASSWORD
repo: 185504a9/sfu
tags: latest
target: run_prod
depends_on:
- staticcheck

2
Dockerfile
View file

@ -6,7 +6,7 @@ ARG uid=1000
RUN mkdir -p "$APP_ROOT" \
&& addgroup --system sfu -g $gid \
&& adduser -h "$APP_ROOT" --disabled-password --system -u $uid --ingroup sfu sfu \
&& apk add curl~=7
&& apk add --no-cache curl~=7
WORKDIR "$APP_ROOT"
USER sfu:sfu

1
README.md
View file

@ -1,4 +1,5 @@
# sfu
[![Build Status](https://qa.roboces.dev/api/badges/catalin/sfu/status.svg)](https://qa.roboces.dev/catalin/sfu)
simple requirementsless, authenticationless file upload server

17
handlers.go
View file

@ -10,7 +10,7 @@ import (
)
func downloadFile(w http.ResponseWriter, req *http.Request, fileName string) {
Info.Println(fmt.Sprintf("server: will download %v", fileName))
Info.Printf("server: will download %v\n", fileName)
file, err := os.Open(fmt.Sprintf("%v/%v", SFU_FILES_DIR, fileName))
if err != nil {
Error.Println(err)
@ -34,9 +34,9 @@ func fileExists(fileName string) bool {
}
func deleteFile(w http.ResponseWriter, req *http.Request, fileName string) {
Info.Println(fmt.Sprintf("server: will delete %v", fileName))
Info.Printf("server: will delete %v\n", fileName)
if !fileExists(fileName) {
Error.Println(fmt.Sprintf("%v does not exist", fileName))
Error.Printf("%v does not exist\n", fileName)
http.Error(w, "File not found", http.StatusNotFound)
return
}
@ -59,12 +59,12 @@ func uploadFile(w http.ResponseWriter, req *http.Request) {
fileExists := fileExists(fileHeader.Filename)
forceOverwrite := req.FormValue("force")
if fileExists && forceOverwrite != "true" {
Error.Println(fmt.Sprintf("file %v already exists", fileHeader.Filename))
Error.Printf("file %v already exists\n", fileHeader.Filename)
http.Error(w, "File already exists", http.StatusConflict)
return
}
if !fileExists || (forceOverwrite == "true" && fileExists) {
Info.Println(fmt.Sprintf("server: will upload %v", fileHeader.Filename))
Info.Printf("server: will upload %v\n", fileHeader.Filename)
out, err := os.Create(fmt.Sprintf("%v/%v", SFU_FILES_DIR, fileHeader.Filename))
if err != nil {
Error.Println(err)
@ -83,15 +83,14 @@ func uploadFile(w http.ResponseWriter, req *http.Request) {
return
}
http.Error(w, "internal server error", http.StatusInternalServerError)
return
}
func listFiles(w http.ResponseWriter, req *http.Request) {
Info.Println(fmt.Sprintf("server: will list uploaded files on %v", SFU_FILES_DIR))
Info.Printf("server: will list uploaded files on %v\n", SFU_FILES_DIR)
files, err := ioutil.ReadDir(SFU_FILES_DIR)
if err != nil {
Warning.Println(fmt.Sprintf("%v does not exist", SFU_FILES_DIR))
Info.Println(fmt.Sprintf("will create %v", SFU_FILES_DIR))
Warning.Printf("%v does not exist\n", SFU_FILES_DIR)
Info.Printf("will create %v\n", SFU_FILES_DIR)
_ = os.Mkdir(SFU_FILES_DIR, os.ModePerm)
}
fmt.Fprint(w, "<html><body><ol>")

20
main.go
View file

@ -12,10 +12,10 @@ var SFU_FILES_DIR string = getEnvvar("SFU_FILES_DIR")
var SFU_PORT string = getEnvvar("SFU_PORT")
func getEnvvar(envvar_name string) string {
Info.Printf("getting envvar %v", envvar_name)
Info.Printf("getting envvar %v\n", envvar_name)
envvar_value, isSet := os.LookupEnv(envvar_name)
if !isSet {
Error.Println(fmt.Sprintf("%v is not set", envvar_name))
Error.Printf("%v is not set\n", envvar_name)
os.Exit(1)
}
return envvar_value
@ -33,9 +33,9 @@ func emptyArray(s []string) []string {
func routeFiles(w http.ResponseWriter, r *http.Request) {
path := r.URL.Path
Info.Println(fmt.Sprintf("received %v on %v", r.Method, path))
Info.Printf("received %v on %v", r.Method, path)
paths := emptyArray(strings.Split(path, "/"))
Info.Println(fmt.Sprintf("paths %v", paths))
Info.Printf("paths %v\n", paths)
switch len(paths) {
case 1:
switch r.Method {
@ -45,8 +45,8 @@ func routeFiles(w http.ResponseWriter, r *http.Request) {
uploadFile(w, r)
default:
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
Warning.Println(fmt.Sprintf("%v not allowed", r.Method))
Error.Println(fmt.Sprintf("will return %v", http.StatusMethodNotAllowed))
Warning.Printf("%v not allowed\n", r.Method)
Error.Printf("will return %v\n", http.StatusMethodNotAllowed)
}
return
case 2:
@ -57,8 +57,8 @@ func routeFiles(w http.ResponseWriter, r *http.Request) {
deleteFile(w, r, paths[1])
default:
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
Warning.Println(fmt.Sprintf("%v not allowed", r.Method))
Error.Println(fmt.Sprintf("will return %v", http.StatusMethodNotAllowed))
Warning.Printf("%v not allowed\n", r.Method)
Error.Printf("will return %v\n", http.StatusMethodNotAllowed)
}
default:
http.Error(w, "Not found", http.StatusNotFound)
@ -87,10 +87,10 @@ func main() {
mux := http.NewServeMux()
mux.HandleFunc("/", route)
port := fmt.Sprintf(":%v", SFU_PORT)
Info.Println(fmt.Sprintf("running SFU on port %v", port))
Info.Printf("running SFU on port %v\n", port)
err := http.ListenAndServe(port, mux)
if err != nil {
Error.Println(fmt.Sprintf("%v port may not be available", port))
Error.Printf("%v port may not be available\n", port)
os.Exit(1)
}
}