How to use QueryParams method of plugin Package

1package rendering2import (3	"context"4	"encoding/json"5	"errors"6	"fmt"7	"io"8	"io/fs"9	"mime"10	"net"11	"net/http"12	"net/url"13	"os"14	"strconv"15	"time"16)17var netTransport = &http.Transport{18	Proxy: http.ProxyFromEnvironment,19	Dial: (&net.Dialer{20		Timeout: 30 * time.Second,21	}).Dial,22	TLSHandshakeTimeout: 5 * time.Second,23}24var netClient = &http.Client{25	Transport: netTransport,26}27var (28	remoteVersionFetchInterval   time.Duration = time.Second * 1529	remoteVersionFetchRetries    uint          = 430	remoteVersionRefreshInterval               = time.Minute * 1531)32func (rs *RenderingService) renderViaHTTP(ctx context.Context, renderKey string, opts Opts) (*RenderResult, error) {33	filePath, err := rs.getNewFilePath(RenderPNG)34	if err != nil {35		return nil, err36	}37	rendererURL, err := url.Parse(rs.Cfg.RendererUrl)38	if err != nil {39		return nil, err40	}41	queryParams := rendererURL.Query()42	url := rs.getURL(opts.Path)43	queryParams.Add("url", url)44	queryParams.Add("renderKey", renderKey)45	queryParams.Add("width", strconv.Itoa(opts.Width))46	queryParams.Add("height", strconv.Itoa(opts.Height))47	queryParams.Add("domain", rs.domain)48	queryParams.Add("timezone", isoTimeOffsetToPosixTz(opts.Timezone))49	queryParams.Add("encoding", opts.Encoding)50	queryParams.Add("timeout", strconv.Itoa(int(opts.Timeout.Seconds())))51	queryParams.Add("deviceScaleFactor", fmt.Sprintf("%f", opts.DeviceScaleFactor))52	rendererURL.RawQuery = queryParams.Encode()53	// gives service some additional time to timeout and return possible errors.54	reqContext, cancel := context.WithTimeout(ctx, getRequestTimeout(opts.TimeoutOpts))55	defer cancel()56	resp, err := rs.doRequest(reqContext, rendererURL, opts.Headers)57	if err != nil {58		return nil, err59	}60	// save response to file61	defer func() {62		if err := resp.Body.Close(); err != nil {63			rs.log.Warn("Failed to close response body", "err", err)64		}65	}()66	err = rs.readFileResponse(reqContext, resp, filePath, url)67	if err != nil {68		return nil, err69	}70	return &RenderResult{FilePath: filePath}, nil71}72func (rs *RenderingService) renderCSVViaHTTP(ctx context.Context, renderKey string, opts CSVOpts) (*RenderCSVResult, error) {73	filePath, err := rs.getNewFilePath(RenderCSV)74	if err != nil {75		return nil, err76	}77	rendererURL, err := url.Parse(rs.Cfg.RendererUrl + "/csv")78	if err != nil {79		return nil, err80	}81	queryParams := rendererURL.Query()82	url := rs.getURL(opts.Path)83	queryParams.Add("url", url)84	queryParams.Add("renderKey", renderKey)85	queryParams.Add("domain", rs.domain)86	queryParams.Add("timezone", isoTimeOffsetToPosixTz(opts.Timezone))87	queryParams.Add("encoding", opts.Encoding)88	queryParams.Add("timeout", strconv.Itoa(int(opts.Timeout.Seconds())))89	rendererURL.RawQuery = queryParams.Encode()90	// gives service some additional time to timeout and return possible errors.91	reqContext, cancel := context.WithTimeout(ctx, getRequestTimeout(opts.TimeoutOpts))92	defer cancel()93	resp, err := rs.doRequest(reqContext, rendererURL, opts.Headers)94	if err != nil {95		return nil, err96	}97	// save response to file98	defer func() {99		if err := resp.Body.Close(); err != nil {100			rs.log.Warn("Failed to close response body", "err", err)101		}102	}()103	_, params, err := mime.ParseMediaType(resp.Header.Get("Content-Disposition"))104	if err != nil {105		return nil, err106	}107	downloadFileName := params["filename"]108	err = rs.readFileResponse(reqContext, resp, filePath, url)109	if err != nil {110		return nil, err111	}112	return &RenderCSVResult{FilePath: filePath, FileName: downloadFileName}, nil113}114func (rs *RenderingService) doRequest(ctx context.Context, url *url.URL, headers map[string][]string) (*http.Response, error) {115	req, err := http.NewRequestWithContext(ctx, "GET", url.String(), nil)116	if err != nil {117		return nil, err118	}119	req.Header.Set("User-Agent", fmt.Sprintf("Grafana/%s", rs.Cfg.BuildVersion))120	for k, v := range headers {121		req.Header[k] = v122	}123	rs.log.Debug("calling remote rendering service", "url", url)124	// make request to renderer server125	resp, err := netClient.Do(req)126	if err != nil {127		rs.log.Error("Failed to send request to remote rendering service", "error", err)128		return nil, fmt.Errorf("failed to send request to remote rendering service: %w", err)129	}130	return resp, nil131}132func (rs *RenderingService) readFileResponse(ctx context.Context, resp *http.Response, filePath string, url string) error {133	// check for timeout first134	if errors.Is(ctx.Err(), context.DeadlineExceeded) {135		rs.log.Info("Rendering timed out")136		return ErrTimeout137	}138	// if we didn't get a 200 response, something went wrong.139	if resp.StatusCode != http.StatusOK {140		rs.log.Error("Remote rendering request failed", "error", resp.Status, "url", url)141		return fmt.Errorf("remote rendering request failed, status code: %d, status: %s", resp.StatusCode,142			resp.Status)143	}144	out, err := os.Create(filePath)145	if err != nil {146		return err147	}148	defer func() {149		if err := out.Close(); err != nil && !errors.Is(err, fs.ErrClosed) {150			// We already close the file explicitly in the non-error path, so shouldn't be a problem151			rs.log.Warn("Failed to close file", "path", filePath, "err", err)152		}153	}()154	_, err = io.Copy(out, resp.Body)155	if err != nil {156		// check that we didn't timeout while receiving the response.157		if errors.Is(ctx.Err(), context.DeadlineExceeded) {158			rs.log.Info("Rendering timed out")159			return ErrTimeout160		}161		rs.log.Error("Remote rendering request failed", "error", err)162		return fmt.Errorf("remote rendering request failed: %w", err)163	}164	if err := out.Close(); err != nil {165		return fmt.Errorf("failed to write to %q: %w", filePath, err)166	}167	return nil168}169func (rs *RenderingService) getRemotePluginVersionWithRetry(callback func(string, error)) {170	go func() {171		var err error172		for try := uint(0); try < remoteVersionFetchRetries; try++ {173			version, err := rs.getRemotePluginVersion()174			if err == nil {175				callback(version, err)176				return177			}178			rs.log.Info("Couldn't get remote renderer version, retrying", "err", err, "try", try)179			time.Sleep(remoteVersionFetchInterval)180		}181		callback("", err)182	}()183}184func (rs *RenderingService) getRemotePluginVersion() (string, error) {185	rendererURL, err := url.Parse(rs.Cfg.RendererUrl + "/version")186	if err != nil {187		return "", err188	}189	headers := make(map[string][]string)190	resp, err := rs.doRequest(context.Background(), rendererURL, headers)191	if err != nil {192		return "", err193	}194	defer func() {195		if err := resp.Body.Close(); err != nil {196			rs.log.Warn("Failed to close response body", "err", err)197		}198	}()199	if resp.StatusCode == http.StatusNotFound {200		// Old versions of the renderer lacked the version endpoint201		return "1.0.0", nil202	} else if resp.StatusCode != http.StatusOK {203		return "", fmt.Errorf("remote rendering request to get version failed, status code: %d, status: %s", resp.StatusCode,204			resp.Status)205	}206	var info struct {207		Version string208	}209	if err := json.NewDecoder(resp.Body).Decode(&info); err != nil {210		return "", err211	}212	return info.Version, nil213}214func (rs *RenderingService) refreshRemotePluginVersion() {215	newVersion, err := rs.getRemotePluginVersion()216	if err != nil {217		rs.log.Info("Failed to refresh remote plugin version", "err", err)218		return219	}220	if newVersion == "" {221		// the image-renderer could have been temporary unavailable - skip updating the version222		rs.log.Debug("Received empty version when trying to refresh remote plugin version")223		return224	}225	currentVersion := rs.Version()226	if currentVersion != newVersion {227		rs.versionMutex.Lock()228		defer rs.versionMutex.Unlock()229		rs.log.Info("Updating remote plugin version", "currentVersion", currentVersion, "newVersion", newVersion)230		rs.version = newVersion231	}232}...

1package contractpb2import (3	"bytes"4	"errors"5	"reflect"6	"github.com/gogo/protobuf/proto"7	"github.com/diademnetwork/go-diadem/plugin"8	"github.com/diademnetwork/go-diadem/plugin/types"9)10// RequestDispatcher dispatches Request(s) to contract methods.11// The dispatcher takes care of unmarshalling requests and marshalling responses from/to protobufs12// or JSON - based on the content type specified in the Request.ContentType/Accept fields.13type RequestDispatcher struct {14	Contract15	callbacks *serviceMap16}17func NewRequestDispatcher(contract Contract) (*RequestDispatcher, error) {18	s := &RequestDispatcher{19		Contract:  contract,20		callbacks: new(serviceMap),21	}22	err := s.callbacks.Register(contract, "contract")23	if err != nil {24		return nil, err25	}26	return s, nil27}28func (s *RequestDispatcher) Init(ctx plugin.Context, req *plugin.Request) error {29	wrappedCtx := WrapPluginContext(ctx)30	body := bytes.NewBuffer(req.Body)31	unmarshaler, err := UnmarshalerFactory(req.ContentType)32	if err != nil {33		return err34	}35	serviceSpec, methodSpec, err := s.callbacks.Get("contract.Init")36	if err != nil {37		return err38	}39	if methodSpec.methodSig != methodSigInit {40		return errors.New("method call does not match method signature type")41	}42	queryParams := reflect.New(methodSpec.argsType)43	err = unmarshaler.Unmarshal(body, queryParams.Interface().(proto.Message))44	if err != nil {45		return err46	}47	resultTypes := methodSpec.method.Func.Call([]reflect.Value{48		serviceSpec.rcvr,49		reflect.ValueOf(wrappedCtx),50		queryParams,51	})52	err, _ = resultTypes[0].Interface().(error)53	return err54}55func (s *RequestDispatcher) StaticCall(ctx plugin.StaticContext, req *plugin.Request) (*plugin.Response, error) {56	return s.doCall(methodSigStaticCall, WrapPluginStaticContext(ctx), req)57}58func (s *RequestDispatcher) Call(ctx plugin.Context, req *plugin.Request) (*plugin.Response, error) {59	return s.doCall(methodSigCall, WrapPluginContext(ctx), req)60}61func (s *RequestDispatcher) doCall(sig methodSig, ctx interface{}, req *plugin.Request) (*plugin.Response, error) {62	body := bytes.NewBuffer(req.Body)63	unmarshaler, err := UnmarshalerFactory(req.ContentType)64	if err != nil {65		return nil, err66	}67	marshaler, err := MarshalerFactory(req.Accept)68	if err != nil {69		return nil, err70	}71	var query types.ContractMethodCall72	err = unmarshaler.Unmarshal(body, &query)73	if err != nil {74		return nil, err75	}76	serviceSpec, methodSpec, err := s.callbacks.Get("contract." + query.Method)77	if err != nil {78		return nil, err79	}80	if methodSpec.methodSig != sig {81		return nil, errors.New("method call does not match method signature type")82	}83	queryParams := reflect.New(methodSpec.argsType)84	err = unmarshaler.Unmarshal(bytes.NewBuffer(query.Args), queryParams.Interface().(proto.Message))85	if err != nil {86		return nil, err87	}88	resultTypes := methodSpec.method.Func.Call([]reflect.Value{89		serviceSpec.rcvr,90		reflect.ValueOf(ctx),91		queryParams,92	})93	var resp bytes.Buffer94	if len(resultTypes) > 0 {95		err, _ = resultTypes[len(resultTypes)-1].Interface().(error)96		if err != nil {97			return nil, err98		}99		pb, _ := resultTypes[0].Interface().(proto.Message)100		if pb != nil {101			err = marshaler.Marshal(&resp, pb)102			if err != nil {103				return nil, err104			}105		}106	}107	return &plugin.Response{108		ContentType: req.Accept,109		Body:        resp.Bytes(),110	}, nil111}...

1import (2type SimpleChaincode struct {3}4func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) peer.Response {5	return shim.Success(nil)6}7func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) peer.Response {8	function, args := stub.GetFunctionAndParameters()9	if function == "query" {10		return t.query(stub, args)11	}12	return shim.Error("Invalid invoke function name. Expecting \"query\"")13}14func (t *SimpleChaincode) query(stub shim.ChaincodeStubInterface, args []string) peer.Response {15	if len(args) != 1 {16		return shim.Error("Incorrect number of arguments. Expecting name of the person to query")17	}18	queryString := fmt.Sprintf("{\"selector\":{\"docType\":\"user\",\"name\":\"%s\"}}", name)19	queryResults, err := getQueryResultForQueryString(stub, queryString)20	if err != nil {21		return shim.Error(err.Error())22	}23	return shim.Success(queryResults)24}25func main() {26	err := shim.Start(new(SimpleChaincode))27	if err != nil {28		fmt.Printf("Error starting Simple chaincode: %s", err)29	}30}31import (32type SimpleChaincode struct {33}34func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) peer.Response {35	return shim.Success(nil)36}37func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) peer.Response {38	function, args := stub.GetFunctionAndParameters()39	if function == "query" {40		return t.query(stub, args)41	}42	return shim.Error("Invalid invoke function name. Expecting \"query\"")43}44func (t *SimpleChaincode) query(stub shim.ChaincodeStubInterface, args []string) peer.Response {45	if len(args) != 1 {

1import (2func main() {3	beego.Get("/queryparams", func(ctx *context.Context) {4		fmt.Println(ctx.Input.Query("name"))5		fmt.Println(ctx.Input.Query("age"))6	})7	beego.Run()8}9import (10func main() {11	beego.Get("/queryparams", func(ctx *context.Context) {12		fmt.Println(ctx.Query("name"))13		fmt.Println(ctx.Query("age"))14	})15	beego.Run()16}17import (18func main() {19	beego.Get("/queryparams", func(ctx *context.Context) {20		fmt.Println(ctx.Request.URL.Query().Get("name"))21		fmt.Println(ctx.Request.URL.Query().Get("age"))22	})23	beego.Run()24}25import (26func main() {27	beego.Get("/queryparams", func() {28		fmt.Println(beego.AppConfig.String("name"))29		fmt.Println(beego.AppConfig.String("age"))30	})31	beego.Run()32}33import (34func main() {35	beego.Get("/queryparams", func() {36		fmt.Println(beego.AppConfig.String("name"))37		fmt.Println(beego.AppConfig.String("age"))38	})39	beego.Run()40}41import (42func main() {43	beego.Get("/queryparams", func() {44		fmt.Println(beego.AppConfig.String("name"))45		fmt.Println(beego.AppConfig.String("age"))46	})47	beego.Run()48}

1import (2func main() {3beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{4AllowMethods: []string{"PUT", "PATCH", "GET", "POST", "DELETE"},5AllowHeaders: []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},6ExposeHeaders: []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},7}))8beego.Run()9}10import (11func main() {12beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{13AllowMethods: []string{"PUT", "PATCH", "GET", "POST", "DELETE"},14AllowHeaders: []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},15ExposeHeaders: []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},16}))17beego.Run()18}19import (20func main() {21beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{22AllowMethods: []string{"PUT", "PATCH", "GET", "POST", "DELETE"},23AllowHeaders: []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},24ExposeHeaders: []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},25}))26beego.Run()27}28import (29func main()

1import (2func main() {3	p, err := plugin.Open("plugin.so")4	if err != nil {5		log.Fatal(err)6	}7	symQueryParams, err := p.Lookup("QueryParams")8	if err != nil {9		log.Fatal(err)10	}11	queryParams, ok := symQueryParams.(func(string) string)12	if !ok {13		log.Fatal("unexpected type from module symbol")14	}15}16import (17func main() {18	p, err := plugin.Open("plugin.so")19	if err != nil {20		log.Fatal(err)21	}22	symQueryParams, err := p.Lookup("QueryParams")23	if err != nil {24		log.Fatal(err)25	}26	queryParams, ok := symQueryParams.(func(string) string)27	if !ok {28		log.Fatal("unexpected type from module symbol")29	}30}31import (32func main() {33	p, err := plugin.Open("plugin.so")34	if err != nil {35		log.Fatal(err)36	}37	symQueryParams, err := p.Lookup("QueryParams")38	if err != nil {39		log.Fatal(err)40	}

1var plugin = new Plugin();2var queryParams = plugin.QueryParams();3var name = queryParams["name"];4var age = queryParams["age"];5var city = queryParams["city"];6var plugin = new Plugin();7var queryParams = plugin.QueryParams();8var name = queryParams["name"];9var age = queryParams["age"];10var city = queryParams["city"];11var plugin = new Plugin();12var queryParams = plugin.QueryParams();13var name = queryParams["name"];14var age = queryParams["age"];15var city = queryParams["city"];16var plugin = new Plugin();17var queryParams = plugin.QueryParams();18var name = queryParams["name"];19var age = queryParams["age"];20var city = queryParams["city"];21var plugin = new Plugin();22var queryParams = plugin.QueryParams();23var name = queryParams["name"];24var age = queryParams["age"];25var city = queryParams["city"];26var plugin = new Plugin();27var queryParams = plugin.QueryParams();28var name = queryParams["name"];29var age = queryParams["age"];30var city = queryParams["city"];31var plugin = new Plugin();32var queryParams = plugin.QueryParams();33var name = queryParams["name"];34var age = queryParams["age"];

1import (2func main() {3  plugin.Init()4}5import (6func main() {7  plugin.Init()8}9import (10func main() {11  plugin.Init()12}13import (14func main() {15  plugin.Init()16}17import (18func main() {19  plugin.Init()20}21import (22func main() {23  plugin.Init()24}25import (26func main() {27  plugin.Init()28}29import (

1func main() {2    plugin := new(plugin.Plugin)3    queryParams := plugin.QueryParams("query")4    fmt.Println(queryParams)5}6func main() {7    plugin := new(plugin.Plugin)8    queryParams := plugin.QueryParams("query")9    fmt.Println(queryParams)10}11func main() {12    plugin := new(plugin.Plugin)13    queryParams := plugin.QueryParams("query")14    fmt.Println(queryParams)15}16func main() {17    plugin := new(plugin.Plugin)18    queryParams := plugin.QueryParams("query")19    fmt.Println(queryParams)20}21func main() {22    plugin := new(plugin.Plugin)23    queryParams := plugin.QueryParams("query")24    fmt.Println(queryParams)25}26func main() {27    plugin := new(plugin.Plugin)28    queryParams := plugin.QueryParams("query")29    fmt.Println(queryParams)30}31func main() {32    plugin := new(plugin.Plugin)33    queryParams := plugin.QueryParams("query")34    fmt.Println(queryParams)35}36func main() {37    plugin := new(plugin.Plugin)38    queryParams := plugin.QueryParams("query")39    fmt.Println(queryParams)40}41func main() {42    plugin := new(plugin.Plugin)

1var plugin = new Plugin();2var queryParams = plugin.QueryParams();3var query = queryParams["query"];4var text = queryParams["text"];5var lang = queryParams["lang"];6var plugin = new Plugin();7var queryParams = plugin.QueryParams();8var query = queryParams["query"];9var text = queryParams["text"];10var lang = queryParams["lang"];11var plugin = new Plugin();12var queryParams = plugin.QueryParams();13var query = queryParams["query"];14var text = queryParams["text"];15var lang = queryParams["lang"];16var plugin = new Plugin();17var queryParams = plugin.QueryParams();18var query = queryParams["query"];19var text = queryParams["text"];20var lang = queryParams["lang"];21var plugin = new Plugin();22var queryParams = plugin.QueryParams();23var query = queryParams["query"];24var text = queryParams["text"];25var lang = queryParams["lang"];26var plugin = new Plugin();27var queryParams = plugin.QueryParams();28var query = queryParams["query"];29var text = queryParams["text"];30var lang = queryParams["lang"];31var plugin = new Plugin();32var queryParams = plugin.QueryParams();33var query = queryParams["query"];34var text = queryParams["text"];35var lang = queryParams["lang"];36var plugin = new Plugin();37var queryParams = plugin.QueryParams();38var query = queryParams["query"];39var text = queryParams["text"];40var lang = queryParams["lang"];41var plugin = new Plugin();42var queryParams = plugin.QueryParams();43var query = queryParams["query"];44var text = queryParams["text"];45var lang = queryParams["lang"];46var plugin = new Plugin();47var queryParams = plugin.QueryParams();48var query = queryParams["query"];49var text = queryParams["text"];50var lang = queryParams["lang"];51var plugin = new Plugin();52var queryParams = plugin.QueryParams();53var query = queryParams["query"];54var text = queryParams["text"];55var lang = queryParams["lang"];