代码拉取完成，页面将自动刷新
// Copyright 2013 gopm authors.
//
// Licensed under the Apache License, Version 2.0 (the "License"): you may
// not use this file except in compliance with the License. You may obtain
// a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
// License for the specific language governing permissions and limitations
// under the License.
package cmd
// import (
// "errors"
// "fmt"
// "github.com/Unknwon/com"
// "github.com/gpmgo/gopm/doc"
// "github.com/syndtr/goleveldb/leveldb"
// "github.com/syndtr/goleveldb/leveldb/opt"
// "io/ioutil"
// "net/http"
// "net/url"
// "os"
// "os/exec"
// "path/filepath"
// "strconv"
// "strings"
// "time"
// )
// var (
// dbDir = "~/.gopm/db"
// )
// const (
// STOP = iota
// LOCALRUN
// RUNNING
// )
// var CmdServe = &Command{
// UsageLine: "serve [:port]",
// Short: "serve for package search",
// Long: `
// serve provide a web service to search packages, download packages
// The serve flags are:
// -l
// only service for localhost ip
// `,
// }
// func init() {
// CmdServe.Run = runServe
// CmdServe.Flags = map[string]bool{
// "-l": false,
// }
// }
// func printServePrompt(flag string) {
// switch flag {
// case "-l":
// com.ColorLog("[INFO] You enabled start a service only localhost.\n")
// }
// }
// // Not implemented
// func autoPort() string {
// return "8991"
// }
// func exePath() (string, error) {
// file, err := exec.LookPath(os.Args[0])
// if err != nil {
// return "", err
// }
// return filepath.Abs(file)
// }
// // search packages
// func runServe(cmd *Command, args []string) {
// // Check flags.
// num := checkFlags(cmd.Flags, args, printServePrompt)
// if num == -1 {
// return
// }
// args = args[num:]
// var listen string
// var port string
// if cmd.Flags["-l"] {
// listen += "127.0.0.1"
// port = autoPort()
// } else {
// listen += "0.0.0.0"
// port = "8991"
// }
// // Check length of arguments.
// if len(args) >= 1 {
// port = args[0]
// }
// err := startService(listen, port)
// if err != nil {
// com.ColorLog("[ERRO] %v\n", err)
// }
// }
// func splitWord(word string, res *map[string]bool) {
// for i, _ := range word {
// for j, _ := range word[i:] {
// w := word[i : i+j+1]
// (*res)[w] = true
// }
// }
// return
// }
// func splitPkgName(pkgName string) (res map[string]bool) {
// //var src string
// ps := strings.Split(pkgName, "/")
// if len(ps) > 1 {
// ps = ps[1:]
// }
// res = make(map[string]bool)
// res[strings.Join(ps, "/")] = true
// for _, w := range ps {
// splitWord(w, &res)
// }
// return
// }
// func splitSynopsis(synopsis string) map[string]bool {
// res := make(map[string]bool)
// ss := strings.Fields(synopsis)
// for _, s := range ss {
// res[s] = true
// }
// return res
// }
// var (
// ro *opt.ReadOptions = &opt.ReadOptions{}
// wo *opt.WriteOptions = &opt.WriteOptions{}
// )
// func dbGet(key string) (string, error) {
// v, err := db.Get([]byte(key), ro)
// return string(v), err
// }
// func dbPut(key string, value string) error {
// //fmt.Println("put ", key, ": ", value)
// return db.Put([]byte(key), []byte(value), wo)
// }
// func batchPut(batch *leveldb.Batch, key string, value string) error {
// //fmt.Println("put ", key, ": ", value)
// batch.Put([]byte(key), []byte(value))
// return nil
// }
// func getServeHost() string {
// return "localhost"
// }
// func getServePort() string {
// return "8991"
// }
// // for exernal of serve to add node to db
// func saveNode(nod *doc.Node) error {
// urlPath := fmt.Sprintf("http://%v:%v/add", getServeHost(), getServePort())
// resp, err := http.PostForm(urlPath,
// url.Values{"importPath": {nod.ImportPath},
// "synopsis": {nod.Synopsis},
// "downloadURL": {nod.DownloadURL},
// "isGetDeps": {strconv.FormatBool(nod.IsGetDeps)},
// "type": {nod.Type},
// "value": {nod.Value}})
// if err != nil {
// com.ColorLog("[ERRO] Fail to save node[ %s ]\n", err)
// return err
// }
// defer resp.Body.Close()
// if resp.StatusCode == 200 {
// return nil
// }
// return errors.New("save node failed with " + resp.Status)
// }
// // for inetrnal of serve to add node to db
// func addNode(nod *doc.Node) error {
// batch := new(leveldb.Batch)
// strLastId, err := dbGet("lastId")
// if err != nil {
// if err == leveldb.ErrNotFound {
// strLastId = "0"
// err = batchPut(batch, "lastId", strLastId)
// } else {
// return err
// }
// }
// if err != nil {
// return err
// }
// lastId, err := strconv.ParseInt(strLastId, 0, 64)
// if err != nil {
// return err
// }
// nodKey := fmt.Sprintf("index:%v", nod.ImportPath)
// id, err := dbGet(nodKey)
// if err != nil {
// if err == leveldb.ErrNotFound {
// id = fmt.Sprintf("%v", lastId+1)
// err = batchPut(batch, "lastId", id)
// if err == nil {
// err = batchPut(batch, nodKey, id)
// }
// if err == nil {
// err = batchPut(batch, "pkg:"+id, nod.ImportPath)
// }
// if err == nil {
// err = batchPut(batch, "desc:"+id, nod.Synopsis)
// }
// if err == nil {
// err = batchPut(batch, "down:"+id, nod.DownloadURL)
// }
// if err == nil {
// err = batchPut(batch, "deps:"+id, strconv.FormatBool(nod.IsGetDeps))
// }
// // save totals
// total, err := dbGet("total")
// if err != nil {
// if err == leveldb.ErrNotFound {
// total = "1"
// } else {
// return err
// }
// } else {
// totalInt, err := strconv.ParseInt(total, 0, 64)
// if err != nil {
// return err
// }
// totalInt = totalInt + 1
// total = fmt.Sprintf("%v", totalInt)
// }
// err = batchPut(batch, "total", total)
// } else {
// return err
// }
// }
// if err != nil {
// return err
// }
// // save vers
// vers, err := dbGet("ver:" + id)
// needSplit := (err == leveldb.ErrNotFound)
// if err != nil {
// if err != leveldb.ErrNotFound {
// return err
// }
// } else {
// return nil
// }
// if vers == "" {
// //fmt.Println(nod)
// vers = nod.VerString()
// } else {
// if !strings.Contains(vers, nod.VerString()) {
// vers = vers + "," + nod.VerString()
// } else {
// return nil
// }
// }
// err = batchPut(batch, "ver:"+id, vers)
// if err != nil {
// return err
// }
// if !needSplit {
// return nil
// }
// // indexing package name
// keys := splitPkgName(nod.ImportPath)
// for key, _ := range keys {
// err = batchPut(batch, fmt.Sprintf("key:%v:%v", strings.ToLower(key), id), "")
// if err != nil {
// return err
// }
// }
// if nod.Synopsis != "" {
// fields := splitSynopsis(nod.Synopsis)
// for field, _ := range fields {
// err = batchPut(batch, fmt.Sprintf("key:%v:%v", strings.ToLower(field), id), "")
// if err != nil {
// return err
// }
// }
// }
// return db.Write(batch, wo)
// }
// func rmPkg(nod *doc.Node) {
// }
// var db *leveldb.DB
// // service should be run
// func AutoRun() error {
// s, _, _ := runningStatus()
// if s == STOP {
// // current path
// curPath, err := os.Getwd()
// if err != nil {
// return err
// }
// attr := &os.ProcAttr{
// Dir: curPath,
// Env: os.Environ(),
// //Files: []*os.File{nil, nil, nil},
// Files: []*os.File{os.Stdin, os.Stdout, os.Stderr},
// }
// p, err := exePath()
// if err != nil {
// return err
// }
// //com.ColorLog("[INFO] now is starting search daemon ...\n")
// _, err = os.StartProcess(p, []string{"gopm", "serve", "-l"}, attr)
// if err != nil {
// return err
// }
// time.Sleep(time.Second)
// }
// return nil
// }
// func runningStatus() (int, int, int) {
// pFile, err := getPidPath()
// if err != nil {
// return STOP, 0, 0
// }
// contentByte, err := ioutil.ReadFile(pFile)
// if err != nil {
// return STOP, 0, 0
// }
// content := string(contentByte)
// if len(content) < 0 || !strings.Contains(content, ",") {
// return STOP, 0, 0
// }
// cs := strings.Split(string(content), ",")
// if len(cs) != 3 {
// return STOP, 0, 0
// }
// status, err := strconv.Atoi(cs[0])
// if err != nil {
// return STOP, 0, 0
// }
// if status < STOP || status > RUNNING {
// return STOP, 0, 0
// }
// pid, err := strconv.Atoi(cs[1])
// if err != nil {
// return STOP, 0, 0
// }
// _, err = os.FindProcess(pid)
// if err != nil {
// return STOP, 0, 0
// }
// port, err := strconv.Atoi(cs[2])
// if err != nil {
// return STOP, 0, 0
// }
// return status, pid, port
// }
// func getPidPath() (string, error) {
// homeDir, err := com.HomeDir()
// if err != nil {
// return "", err
// }
// pFile := strings.Replace("~/.gopm/var/", "~", homeDir, -1)
// os.MkdirAll(pFile, os.ModePerm)
// return pFile + "pid", nil
// }
// func startService(listen, port string) error {
// homeDir, err := com.HomeDir()
// if err != nil {
// return err
// }
// pFile, err := getPidPath()
// if err != nil {
// return err
// }
// f, err := os.OpenFile(pFile, os.O_RDWR|os.O_CREATE, 0700)
// if err != nil {
// return err
// }
// defer f.Close()
// _, err = f.WriteString(fmt.Sprintf("%v,%v,%v", RUNNING, os.Getpid(), port))
// if err != nil {
// return err
// }
// dbDir = strings.Replace(dbDir, "~", homeDir, -1)
// db, err = leveldb.OpenFile(dbDir, nil)
// if err != nil {
// return err
// }
// defer db.Close()
// // these handlers should only access by localhost
// http.HandleFunc("/add", addHandler)
// http.HandleFunc("/rm", rmHandler)
// // these handlers can be accessed according listen's ip
// http.HandleFunc("/search", searchHandler)
// http.HandleFunc("/searche", searcheHandler)
// http.ListenAndServe(listen+":"+port, nil)
// return nil
// }
// func searchHandler(w http.ResponseWriter, r *http.Request) {
// r.ParseForm()
// ids := make(map[string]bool)
// for key, _ := range r.Form {
// iter := db.NewIterator(ro)
// rkey := fmt.Sprintf("key:%v:", strings.ToLower(key))
// if iter.Seek([]byte(rkey)) {
// k := iter.Key()
// if !strings.HasPrefix(string(k), rkey) {
// break
// } else {
// ids[string(k)] = true
// }
// }
// for iter.Next() {
// k := iter.Key()
// if !strings.HasPrefix(string(k), rkey) {
// break
// }
// ids[string(k)] = true
// }
// }
// pkgs := make([]string, 0)
// for id, _ := range ids {
// idkeys := strings.SplitN(id, ":", -1)
// rId := idkeys[len(idkeys)-1]
// //fmt.Println(rId)
// pkg, err := dbGet(fmt.Sprintf("pkg:%v", rId))
// if err != nil {
// com.ColorLog(err.Error())
// continue
// }
// desc, err := dbGet(fmt.Sprintf("desc:%v", rId))
// if err != nil {
// com.ColorLog(err.Error())
// continue
// }
// pkgs = append(pkgs, fmt.Sprintf(`{"pkg":"%v", "desc":"%v"}`, pkg, desc))
// }
// w.Write([]byte("[" + strings.Join(pkgs, ", ") + "]"))
// }
// func searcheHandler(w http.ResponseWriter, r *http.Request) {
// //if r.Method == "POST" {
// r.ParseForm()
// pkgs := make([]string, 0)
// for key, _ := range r.Form {
// rId, err := dbGet("index:" + key)
// if err != nil {
// com.ColorLog(err.Error())
// continue
// }
// desc, err := dbGet(fmt.Sprintf("desc:%v", rId))
// if err != nil {
// com.ColorLog(err.Error())
// continue
// }
// pkgs = append(pkgs, fmt.Sprintf(`{"pkg":"%v", "desc":"%v"}`, key, desc))
// }
// w.Write([]byte("[" + strings.Join(pkgs, ", ") + "]"))
// //}
// }
// func addHandler(w http.ResponseWriter, r *http.Request) {
// //if r.Method == "POST" {
// r.ParseForm()
// nod := new(doc.Node)
// nod.ImportPath = r.FormValue("importPath")
// nod.Synopsis = r.FormValue("synopsis")
// nod.DownloadURL = r.FormValue("downloadURL")
// isGetDeps, err := strconv.ParseBool(r.FormValue("isGetDeps"))
// if err != nil {
// com.ColorLog("[ERRO] SEVER: Cannot get deps")
// }
// nod.IsGetDeps = isGetDeps
// nod.Type = r.FormValue("type")
// nod.Value = r.FormValue("value")
// err = addNode(nod)
// if err != nil {
// com.ColorLog("[ERRO] SEVER: Cannot add node[ %s ]\n", err)
// }
// //}
// }
// func rmHandler(w http.ResponseWriter, r *http.Request) {
// }
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手