Initial code
Version 0.0.1!
This commit is contained in:
Amrit Panesar committed
1 parent
7859695c1f
commit
21e5071bea
11 files changed
+308
No files matched your search
+118
@@ -1,3 +1,5 @@
|
||||
code/
|
||||
|
||||
# Binaries for programs and plugins
|
||||
*.exe
|
||||
*.dll
|
||||
@@ -12,3 +14,119 @@
|
||||
|
||||
# Project-local glide cache, RE: https://github.com/Masterminds/glide/issues/736
|
||||
.glide/
|
||||
|
||||
### JetBrains template
|
||||
# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
|
||||
# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
|
||||
|
||||
# User-specific stuff:
|
||||
.idea/**/workspace.xml
|
||||
.idea/**/tasks.xml
|
||||
.idea/dictionaries
|
||||
|
||||
# Sensitive or high-churn files:
|
||||
.idea/**/dataSources/
|
||||
.idea/**/dataSources.ids
|
||||
.idea/**/dataSources.xml
|
||||
.idea/**/dataSources.local.xml
|
||||
.idea/**/sqlDataSources.xml
|
||||
.idea/**/dynamic.xml
|
||||
.idea/**/uiDesigner.xml
|
||||
|
||||
# Gradle:
|
||||
.idea/**/gradle.xml
|
||||
.idea/**/libraries
|
||||
|
||||
# CMake
|
||||
cmake-build-debug/
|
||||
|
||||
# Mongo Explorer plugin:
|
||||
.idea/**/mongoSettings.xml
|
||||
|
||||
## File-based project format:
|
||||
*.iws
|
||||
|
||||
## Plugin-specific files:
|
||||
|
||||
# IntelliJ
|
||||
out/
|
||||
|
||||
# mpeltonen/sbt-idea plugin
|
||||
.idea_modules/
|
||||
|
||||
# JIRA plugin
|
||||
atlassian-ide-plugin.xml
|
||||
|
||||
# Cursive Clojure plugin
|
||||
.idea/replstate.xml
|
||||
|
||||
# Crashlytics plugin (for Android Studio and IntelliJ)
|
||||
com_crashlytics_export_strings.xml
|
||||
crashlytics.properties
|
||||
crashlytics-build.properties
|
||||
fabric.properties
|
||||
### Linux template
|
||||
*~
|
||||
|
||||
# temporary files which can be created if a process still has a handle open of a deleted file
|
||||
.fuse_hidden*
|
||||
|
||||
# KDE directory preferences
|
||||
.directory
|
||||
|
||||
# Linux trash folder which might appear on any partition or disk
|
||||
.Trash-*
|
||||
|
||||
# .nfs files are created when an open file is removed but is still being accessed
|
||||
.nfs*
|
||||
### macOS template
|
||||
# General
|
||||
.DS_Store
|
||||
.AppleDouble
|
||||
.LSOverride
|
||||
|
||||
# Icon must end with two \r
|
||||
Icon
|
||||
|
||||
# Thumbnails
|
||||
._*
|
||||
|
||||
# Files that might appear in the root of a volume
|
||||
.DocumentRevisions-V100
|
||||
.fseventsd
|
||||
.Spotlight-V100
|
||||
.TemporaryItems
|
||||
.Trashes
|
||||
.VolumeIcon.icns
|
||||
.com.apple.timemachine.donotpresent
|
||||
|
||||
# Directories potentially created on remote AFP share
|
||||
.AppleDB
|
||||
.AppleDesktop
|
||||
Network Trash Folder
|
||||
Temporary Items
|
||||
.apdisk
|
||||
### Windows template
|
||||
# Windows thumbnail cache files
|
||||
Thumbs.db
|
||||
ehthumbs.db
|
||||
ehthumbs_vista.db
|
||||
|
||||
# Dump file
|
||||
*.stackdump
|
||||
|
||||
# Folder config file
|
||||
[Dd]esktop.ini
|
||||
|
||||
# Recycle Bin used on file shares
|
||||
$RECYCLE.BIN/
|
||||
|
||||
# Windows Installer files
|
||||
*.cab
|
||||
*.msi
|
||||
*.msm
|
||||
*.msp
|
||||
|
||||
# Windows shortcuts
|
||||
*.lnk
|
||||
|
||||
Generated
+8
@@ -0,0 +1,8 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<module type="WEB_MODULE" version="4">
|
||||
<component name="NewModuleRootManager">
|
||||
<content url="file://$MODULE_DIR$" />
|
||||
<orderEntry type="inheritedJdk" />
|
||||
<orderEntry type="sourceFolder" forTests="false" />
|
||||
</component>
|
||||
</module>
|
||||
Generated
+9
@@ -0,0 +1,9 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="GoImports">
|
||||
<option name="groupStdlibImports" value="true" />
|
||||
<option name="importSorting" value="GOIMPORTS" />
|
||||
<option name="moveAllImportsInOneDeclaration" value="true" />
|
||||
<option name="moveAllStdlibImportsInOneGroup" value="true" />
|
||||
</component>
|
||||
</project>
|
||||
Generated
+8
@@ -0,0 +1,8 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="ProjectModuleManager">
|
||||
<modules>
|
||||
<module fileurl="file://$PROJECT_DIR$/.idea/go-fische.iml" filepath="$PROJECT_DIR$/.idea/go-fische.iml" />
|
||||
</modules>
|
||||
</component>
|
||||
</project>
|
||||
Generated
+6
@@ -0,0 +1,6 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="VcsDirectoryMappings">
|
||||
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
||||
</component>
|
||||
</project>
|
||||
Generated
+29
@@ -0,0 +1,29 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="ProjectTasksOptions">
|
||||
<TaskOptions isEnabled="true">
|
||||
<option name="arguments" value="-w $FilePath$" />
|
||||
<option name="checkSyntaxErrors" value="true" />
|
||||
<option name="description" />
|
||||
<option name="exitCodeBehavior" value="ERROR" />
|
||||
<option name="fileExtension" value="go" />
|
||||
<option name="immediateSync" value="false" />
|
||||
<option name="name" value="goimports" />
|
||||
<option name="output" value="$FilePath$" />
|
||||
<option name="outputFilters">
|
||||
<array />
|
||||
</option>
|
||||
<option name="outputFromStdout" value="false" />
|
||||
<option name="program" value="goimports.exe" />
|
||||
<option name="runOnExternalChanges" value="false" />
|
||||
<option name="scopeName" value="Project Files" />
|
||||
<option name="trackOnlyRoot" value="true" />
|
||||
<option name="workingDir" value="" />
|
||||
<envs>
|
||||
<env name="GOROOT" value="$GOROOT$" />
|
||||
<env name="GOPATH" value="$GOPATH$" />
|
||||
<env name="PATH" value="$PATH$;$GoBinDirs$" />
|
||||
</envs>
|
||||
</TaskOptions>
|
||||
</component>
|
||||
</project>
|
||||
File renamed without changes.
File renamed without changes.
Binary file not shown.
|
After Width: | Height: | Size: 28 KiB |
@@ -0,0 +1,129 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"bufio"
|
||||
"fmt"
|
||||
"log"
|
||||
"net"
|
||||
"os"
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
"github.com/spf13/pflag"
|
||||
"github.com/spf13/viper"
|
||||
)
|
||||
|
||||
const AppName = "Go-Fiche"
|
||||
|
||||
const slugMap = "AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz0123456789"
|
||||
|
||||
var (
|
||||
GitCommit,
|
||||
GitBranch,
|
||||
GitState,
|
||||
BuildDate,
|
||||
Version string
|
||||
)
|
||||
|
||||
func init() {
|
||||
pflag.BoolP("help", "h", false, "Prints this help message")
|
||||
pflag.StringP("output", "o", "./code", "Relative or absolute path to the directory where you want to store user-posted pastes.")
|
||||
pflag.StringP("domain", "d", "localhost", "This will be used as a prefix for an output received by the client. Value will be prepended with http[s].")
|
||||
pflag.IntP("port", "p", 9999, "Port in which the service should listen on.")
|
||||
pflag.BoolP("https", "S", false, fmt.Sprintf("If set, %s returns url with https prefix instead of http.", AppName))
|
||||
pflag.StringP("username", "u", "", fmt.Sprintf("%s will try to switch to the requested user on startup if any is provided.", AppName))
|
||||
pflag.IntP("buffer", "B", 32768, "This parameter defines size of the buffer used for getting data from the user. Maximum size (in bytes) of all input files is defined by this value.")
|
||||
pflag.StringP("log", "l", "", "Log file. This file has to be user-writable.")
|
||||
pflag.Parse()
|
||||
viper.BindPFlags(pflag.CommandLine)
|
||||
|
||||
if viper.GetBool("help") {
|
||||
fmt.Printf("%s!\n Version %s, Built: %s [%s:%s-%s)\n\n", AppName, Version, BuildDate, GitBranch, GitCommit, GitState)
|
||||
pflag.Usage()
|
||||
os.Exit(2)
|
||||
}
|
||||
|
||||
if viper.GetBool("https") {
|
||||
viper.Set("uriprefix", "https")
|
||||
} else {
|
||||
viper.Set("uriprefix", "http")
|
||||
}
|
||||
}
|
||||
|
||||
func main() {
|
||||
log.Printf("Starting %s on %s...", AppName, time.Now().Format(time.RFC822Z))
|
||||
listener, err := net.Listen("tcp", fmt.Sprintf(":%d", viper.Get("port")))
|
||||
if err != nil {
|
||||
// handle error
|
||||
log.Fatalf("Could not bind to port: %d!", viper.Get("port"))
|
||||
os.Exit(-1)
|
||||
}
|
||||
log.Printf("Server started listening on port: %d.", viper.Get("port"))
|
||||
for {
|
||||
conn, err := listener.Accept()
|
||||
if err != nil {
|
||||
log.Printf("Error on accepting connection!")
|
||||
continue
|
||||
}
|
||||
go handleConnection(conn)
|
||||
}
|
||||
time.Sleep(5)
|
||||
os.Exit(0)
|
||||
}
|
||||
|
||||
func generateSlug(seed int64) string {
|
||||
stringSeed := fmt.Sprintf("%d", seed)
|
||||
evenLength := (len(stringSeed) / 2) * 2
|
||||
digitHold := int64(0)
|
||||
out := ""
|
||||
for i := 0; i < evenLength; i += 2 {
|
||||
digitHold, _ = strconv.ParseInt(stringSeed[i:i+2], 10, 8)
|
||||
digitHold = digitHold % int64(len(slugMap))
|
||||
out += slugMap[digitHold : digitHold+1]
|
||||
}
|
||||
return out
|
||||
}
|
||||
|
||||
func handleConnection(conn net.Conn) {
|
||||
remoteHost, err := net.LookupCNAME(conn.RemoteAddr().String())
|
||||
if err != nil {
|
||||
remoteHost = conn.RemoteAddr().String()
|
||||
}
|
||||
defer func() {
|
||||
log.Printf("Closing connection to: %s (%s).\n", remoteHost, conn.RemoteAddr())
|
||||
conn.Close()
|
||||
}()
|
||||
log.Printf("Incoming connection from: %s (%s).\n", remoteHost, conn.RemoteAddr())
|
||||
conn.SetReadDeadline(time.Now().Add(time.Second * 5))
|
||||
|
||||
slug := generateSlug(time.Now().UnixNano())
|
||||
slugFullpath := fmt.Sprintf("%s/%s", viper.GetString("output"), slug)
|
||||
log.Printf("Writing file to %s", slugFullpath)
|
||||
|
||||
file, err := os.Create(slugFullpath)
|
||||
if err != nil {
|
||||
log.Fatalf("Unable to create slug file: %s", slugFullpath)
|
||||
return
|
||||
}
|
||||
|
||||
scanner := bufio.NewScanner(conn)
|
||||
for scanner.Scan() {
|
||||
file.WriteString(scanner.Text())
|
||||
file.Write([]byte("\n"))
|
||||
conn.SetReadDeadline(time.Now().Add(time.Second * 5))
|
||||
}
|
||||
|
||||
stat, _ := file.Stat()
|
||||
if stat.Size() <= 0 {
|
||||
file.Close()
|
||||
log.Printf("0 bytes received, aborting...")
|
||||
os.Remove(slugFullpath)
|
||||
return
|
||||
} else {
|
||||
file.Close()
|
||||
}
|
||||
|
||||
log.Printf("Wrote %d bytes to %s", stat.Size(), slugFullpath)
|
||||
|
||||
conn.Write([]byte(fmt.Sprintf("%s://%s/%s\r\n", viper.GetString("uriprefix"), viper.GetString("domain"), slug)))
|
||||
}
|
||||
Reference in new issue
Block a user