How to use LocalName method of html Package

Best K6 code snippet using html.LocalName

pluginmanager.go

Source:pluginmanager.go Github

copy

Full Screen

...58 pm.stateLock.Lock()59 pm.initialPluginLoadInProgress = true60 mStates, _ := pm.ReadAllInstalledPluginsFromDisk()61 for _, mState := range mStates {62 pm.state[mState.LocalName] = mState63 }64 pm.initialPluginLoadInProgress = false65 pm.updateDcsLuaIndex()6667 pm.stateLock.Unlock()6869 jsonAPI.RegisterType("install_plugin", InstallPluginRequest{})70 jsonAPI.RegisterApiCall("install_plugin", pm.HandleInstallPluginRequest)7172 jsonAPI.RegisterType("remove_plugin", RemovePluginListRequest{})73 jsonAPI.RegisterApiCall("remove_plugin", pm.HandleRemovePluginRequest)7475 jsonAPI.RegisterType("monitor_plugin_list", MonitorPluginListRequest{})76 jsonAPI.RegisterType("plugin_list", PluginList(nil))77 jsonAPI.RegisterApiCall("monitor_plugin_list", pm.HandleMonitorPluginListRequest)7879 jsonAPI.RegisterType("check_for_plugin_updates", CheckForPluginUpdatesRequest{})80 jsonAPI.RegisterApiCall("check_for_plugin_updates", pm.HandleCheckForPluginUpdatesRequest)8182 jsonAPI.RegisterType("apply_plugin_updates", ApplyPluginUpdatesRequest{})83 jsonAPI.RegisterApiCall("apply_plugin_updates", pm.HandleApplyPluginUpdateRequest)8485 pm.registerPluginCatalogApi()8687 return pm, nil88}8990// PluginState describes the current state of a module definition that has been installed91// or is in the process of being installed, updated or removed.92type PluginState struct {93 LocalName string `json:"localName"` // Name of the on-disk folder94 RemoteURL string `json:"remoteURL"` // remote URL (origin)95 CheckedOutCommitHash string `json:"checkedOutCommitHash"` // the commit hash that is currently checked out (HEAD)96 CheckedOutTags []string `json:"checkedOutTags"` // The tags that point to the current HEAD97 CheckedOutBranch string `json:"checkedOutBranch"` // the checked out branch. Empty if in detached head state.98 CanApplyUpdates bool `json:"canApplyUpdates"` // true if HEAD is a branch and the remote branch differs99 Tags []string `json:"tags"` // available tags that can be checked out100 Branches []string `json:"branches"` // available remote branches that can be checked out101 IsManagedManually bool `json:"isManagedManually"` // if true, this repository will not be touched by the plugin manager102 ProgressMessage string `json:"progressMessage"`103 ProgressState string `json:"progressState"` // "", "working", "error", "success"104 IsLoaded bool `json:"isLoaded"` // true if the plugin was loaded correctly105 LoadError string `json:"loadError"` // if IsLoaded is false, this contains the error description106 ModuleDefinitionName string `json:"moduleDefinitionName"`107}108109type MonitorPluginListRequest struct {110}111type PluginList []PluginState112113func (pm *pluginManager) HandleMonitorPluginListRequest(req *MonitorPluginListRequest, responseCh chan<- interface{}, followupCh <-chan interface{}) {114 subscription := make(chan []PluginState)115 go func() {116 defer close(responseCh)117 for newState := range subscription {118 select {119 case responseCh <- PluginList(newState):120 case _, ok := <-followupCh:121 if !ok {122 pm.stateLock.Lock()123 defer pm.stateLock.Unlock()124 delete(pm.stateSubscriptions, subscription)125 return126 }127 }128129 }130 }()131132 pm.stateLock.Lock()133 pm.stateSubscriptions[subscription] = true134 stateCopy := make([]PluginState, 0, len(pm.state))135 names := make([]string, 0, len(pm.state))136 for name := range pm.state {137 names = append(names, name)138 }139 sort.Strings(names)140 for _, name := range names {141 stateCopy = append(stateCopy, *pm.state[name])142 }143 pm.stateLock.Unlock()144 subscription <- stateCopy145146 <-followupCh // wait for connection to be closed147148}149150type RemovePluginListRequest struct {151 LocalName string152}153154func (pm *pluginManager) HandleRemovePluginRequest(req *RemovePluginListRequest, responseCh chan<- interface{}, followupCh <-chan interface{}) {155 defer close(responseCh)156 pm.stateLock.Lock()157 mState, ok := pm.state[req.LocalName]158 if !ok || mState.IsManagedManually {159 pm.stateLock.Unlock()160 responseCh <- jsonapi.ErrorResult{161 Message: "plugin is not installed or is manually managed: " + req.LocalName,162 }163 return164 }165166 if mState.ProgressState == "working" {167 pm.stateLock.Unlock()168 responseCh <- jsonapi.ErrorResult{169 Message: "module definition " + req.LocalName + " is locked by another operation.",170 }171 return172 }173174 mState.ProgressState = "working"175 mState.ProgressMessage = "removing..."176 pm.unloadPlugin(mState)177 pm.notifyStateObservers()178 pm.stateLock.Unlock()179180 err := os.RemoveAll(filepath.Join(pm.CheckoutPath, req.LocalName))181182 pm.stateLock.Lock()183 delete(pm.state, req.LocalName)184 pm.updateDcsLuaIndex()185 pm.notifyStateObservers()186 pm.stateLock.Unlock()187188 if err == nil {189 responseCh <- jsonapi.SuccessResult{}190 } else {191 responseCh <- jsonapi.ErrorResult{192 Message: err.Error(),193 }194 }195}196197type InstallPluginRequest struct {198 RemoteURL string `json:"remoteURL"`199}200201func localNameFromRemoteURL(url *url.URL) string {202 localName := path.Base(url.Path)203 if strings.Trim(localName, ". /\\") == "" {204 return url.String()205 }206 if localName == ".git" {207 localName = path.Base(url.Path)208 }209 localName = strings.TrimSuffix(localName, ".git")210 return localName211}212213func (pm *pluginManager) HandleInstallPluginRequest(req *InstallPluginRequest, responseCh chan<- interface{}, followupCh <-chan interface{}) {214 pm.stateLock.Lock()215216 // check if plugin is already installed217 for _, state := range pm.state {218 if strings.ToLower(state.RemoteURL) == strings.ToLower(req.RemoteURL) {219 pm.stateLock.Unlock()220 responseCh <- jsonapi.ErrorResult{221 Message: "plugin is already installed.",222 }223 close(responseCh)224 return225 }226 }227228 // determine local URL from module name229 url, err := url.Parse(req.RemoteURL)230 if err == nil && !(url.Scheme == "http" || url.Scheme == "https" || url.Scheme == "file") {231 err = errors.New("URL must start with https:// or http:// or file://")232 }233 if err != nil {234 pm.stateLock.Unlock()235 responseCh <- jsonapi.ErrorResult{236 Message: "invalid remote URL: " + req.RemoteURL + ": " + err.Error(),237 }238 close(responseCh)239 return240 }241242 localName := localNameFromRemoteURL(url)243244 // make sure that localName is unique by appending a number if necessary245 suffix := ""246 suffixCnt := 0247 for _, ok := pm.state[localName+suffix]; ok; {248 suffixCnt++249 suffix = strconv.Itoa(suffixCnt)250 }251 localName += suffix252253 pm.state[localName] = &PluginState{254 LocalName: localName,255 ProgressState: "working",256 ProgressMessage: "installing...",257 CheckedOutTags: make([]string, 0),258 Tags: make([]string, 0),259 Branches: make([]string, 0),260 }261 pm.notifyStateObservers()262 pm.stateLock.Unlock()263264 responseCh <- jsonapi.SuccessResult{265 Message: "installing.",266 }267 close(responseCh)268269 err = pm.InstallModuleDefinition(localName, req.RemoteURL)270271 pm.stateLock.Lock()272 defer pm.stateLock.Unlock()273 if err != nil {274 pm.state[localName].ProgressState = "error"275 pm.state[localName].ProgressMessage = err.Error()276 pm.notifyStateObservers()277 }278279 pm.state[localName].ProgressState = "success"280 pm.state[localName].ProgressMessage = "installed."281 pm.notifyStateObservers()282}283284func (pm *pluginManager) ReadSinglePluginStateFromDisk(localName string) (*PluginState, error) {285 repo, err := git.PlainOpen(filepath.Join(pm.CheckoutPath, localName))286 if err != nil {287 return nil, err288 }289 state := &PluginState{290 LocalName: localName,291 CheckedOutTags: make([]string, 0),292 Tags: make([]string, 0),293 Branches: make([]string, 0),294 }295296 // determine remoteURL297 origin, err := repo.Remote(PluginManagerRemoteName)298 if err != nil {299 state.IsManagedManually = true300 } else {301 if len(origin.Config().URLs) == 1 {302 state.RemoteURL = origin.Config().URLs[0]303 }304 }305306 // determine current HEAD state307 head, err := repo.Head()308 if err != nil {309 return nil, err310 }311 if head.Name().IsBranch() {312 state.CheckedOutBranch = head.Name().Short()313 // check remote tracking branch314 if !state.IsManagedManually {315 ref, err := repo.Reference(plumbing.NewRemoteReferenceName(PluginManagerRemoteName, head.Name().Short()), true)316 if err != nil {317 fmt.Printf("error resolving ref: %v\n", err)318 }319 if err == nil {320 if ref.Hash() != head.Hash() {321 state.CanApplyUpdates = true322 }323 }324 }325 } else {326 state.CheckedOutBranch = ""327 }328 state.CheckedOutCommitHash = head.Hash().String()329330 // list tags331 tags, err := repo.Tags()332 if err != nil {333 return nil, err334 }335 tags.ForEach(func(tag *plumbing.Reference) error {336 //fmt.Printf("tag: %v %v %v\n", tag.Target(), tag.Name(), tag.Hash())337 state.Tags = append(state.Tags, tag.Name().Short())338 if tag.Hash() == head.Hash() {339 state.CheckedOutTags = append(state.CheckedOutTags, tag.Name().Short())340 }341 return nil342 })343344 // list branches345 refIter, err := repo.Branches()346 if err != nil {347 return nil, err348 }349 refIter.ForEach(func(branch *plumbing.Reference) error {350 state.Branches = append(state.Branches, branch.Name().Short())351 return nil352 })353354 // determine remote branches355 refs, err := repo.References()356 refs.ForEach(func(ref *plumbing.Reference) error {357 if ref.Name().IsRemote() {358 state.Branches = append(state.Branches, ref.Name().Short())359 }360 return nil361 })362363 type pluginManifest struct {364 ManifestVersion int `json:"manifestVersion"`365 ModuleDefinitionName string `json:"moduleDefinitionName"`366 }367368 // check for manifest369 manifestFilename := filepath.Join(pm.CheckoutPath, localName, "dcs-bios-plugin-manifest.json")370 stat, err := os.Stat(manifestFilename)371 if err == nil && !stat.IsDir() {372 file, err := os.Open(manifestFilename)373 if err == nil {374 defer file.Close()375 dec := json.NewDecoder(file)376 var manifest pluginManifest377 err = dec.Decode(&manifest)378 if err == nil {379 if manifest.ManifestVersion == 1 {380 if manifest.ModuleDefinitionName != "" {381 state.ModuleDefinitionName = manifest.ModuleDefinitionName382 }383 } else {384 state.LoadError = "invalid manifest version"385 }386 }387 }388389 }390391 return state, nil392}393394func (pm *pluginManager) loadPlugin(state *PluginState) {395 if state.ModuleDefinitionName != "" {396 jsonPath := filepath.Join(pm.CheckoutPath, state.LocalName, state.ModuleDefinitionName+".json")397 pm.controlReferenceStore.LoadFile(jsonPath)398 pm.updateDcsLuaIndex()399 }400}401402func (pm *pluginManager) unloadPlugin(state *PluginState) {403 if state.ModuleDefinitionName != "" {404 pm.controlReferenceStore.UnloadModuleDefinition(state.ModuleDefinitionName)405 }406 pm.updateDcsLuaIndex()407 return408}409410// ReadAllInstalledPluginsFromDisk returns a list of currently installed411// module definitions.412func (pm *pluginManager) ReadAllInstalledPluginsFromDisk() ([]*PluginState, error) {413 files, err := ioutil.ReadDir(pm.CheckoutPath)414 if err != nil {415 return nil, err416 }417418 pluginStateList := make([]*PluginState, 0)419 for _, f := range files {420 if !f.IsDir() {421 continue422 }423 state, err := pm.ReadSinglePluginStateFromDisk(f.Name())424 if err != nil {425 return nil, err426 }427 pluginStateList = append(pluginStateList, state)428 pm.loadPlugin(state)429 }430 return pluginStateList, nil431}432433type CheckForPluginUpdatesRequest struct{}434435func (pm *pluginManager) HandleCheckForPluginUpdatesRequest(req *CheckForPluginUpdatesRequest, responseCh chan<- interface{}, followupCh <-chan interface{}) {436 defer close(responseCh)437438 pluginNamesToCheck := make([]string, 0)439 pm.stateLock.Lock()440 for localName, state := range pm.state {441 if state.IsManagedManually { // handle manually managed repositories442 pm.unloadPlugin(state)443 // manual repos: just re-read current state444 newState, err := pm.ReadSinglePluginStateFromDisk(state.LocalName)445 if err != nil {446 state.ProgressState = "error"447 state.ProgressMessage = "failed to read from disk: " + err.Error()448 } else {449 pm.state[state.LocalName] = newState450 pm.loadPlugin(newState)451 }452 continue453 }454455 if state.ProgressState == "working" {456 continue // skip plugins that are already being worked on457 }458 pluginNamesToCheck = append(pluginNamesToCheck, localName)459 state.ProgressState = "working"460 state.ProgressMessage = "wait for update check"461 }462 pm.notifyStateObservers()463 pm.stateLock.Unlock()464465 fetchJobChannel := make(chan string)466 const numConcurrentFetches = 2467 wg := sync.WaitGroup{}468 wg.Add(numConcurrentFetches)469 for i := 0; i < numConcurrentFetches; i++ {470 go func() {471 for localName := range fetchJobChannel {472 pm.stateLock.Lock()473 state := pm.state[localName]474 state.ProgressMessage = "checking for updates"475 pm.notifyStateObservers()476 pm.stateLock.Unlock()477478 err := pm.CheckForUpdates(localName)479 if err == git.NoErrAlreadyUpToDate {480 err = nil481 }482483 pm.stateLock.Lock()484 var newState *PluginState485 if err == nil {486 newState, err = pm.ReadSinglePluginStateFromDisk(localName)487 }488489 if err != nil {490 pm.state[localName].ProgressState = "error"491 pm.state[localName].ProgressMessage = err.Error()492 } else {493 pm.state[localName] = newState494 pm.state[localName].ProgressState = "success"495 }496 pm.notifyStateObservers()497 pm.stateLock.Unlock()498499 }500 }()501502 responseCh <- jsonapi.SuccessResult{503 Message: "started update checks",504 }505 }506507 go func() {508 for _, name := range pluginNamesToCheck {509 fetchJobChannel <- name510 }511 close(fetchJobChannel)512 }()513 wg.Wait()514515}516517func (pm *pluginManager) CheckForUpdates(localName string) error {518 repo, err := git.PlainOpen(filepath.Join(pm.CheckoutPath, localName))519 if err != nil {520 return err521 }522 err = repo.Fetch(&git.FetchOptions{523 RemoteName: PluginManagerRemoteName,524 Tags: git.AllTags,525 })526 if err != nil {527 return err528 }529530 return nil531}532533func (pm *pluginManager) startWorkOnPlugin(localName string, progressMessage string) (state *PluginState, ok bool) {534 pm.stateLock.Lock()535 defer pm.stateLock.Unlock()536 state, ok = pm.state[localName]537 if !ok {538 return nil, false539 }540 if state.ProgressState == "working" {541 return nil, false542 }543 state.ProgressState = "working"544 state.ProgressMessage = progressMessage545 return state, true546}547548func (pm *pluginManager) finishWorkOnPlugin(localName string, progressState, progressMessage string) {549 pm.stateLock.Lock()550 defer pm.stateLock.Unlock()551 state, ok := pm.state[localName]552 if !ok {553 return554 }555 state.ProgressState = progressState556 state.ProgressMessage = progressMessage557 pm.notifyStateObservers()558}559560type ApplyPluginUpdatesRequest struct {561 LocalName string `json:"localName"`562}563564func (pm *pluginManager) HandleApplyPluginUpdateRequest(req *ApplyPluginUpdatesRequest, responseCh chan<- interface{}, followupCh <-chan interface{}) {565 defer close(responseCh)566567 currentState, ok := pm.startWorkOnPlugin(req.LocalName, "applying updates...")568 if !ok {569 responseCh <- jsonapi.ErrorResult{570 Message: "Plugin does not exist or is already in use.",571 }572 return573 }574575 pm.unloadPlugin(currentState)576 err := pm.ApplyUpdates(currentState.LocalName)577578 if err != nil {579 pm.finishWorkOnPlugin(req.LocalName, "error", err.Error())580 responseCh <- jsonapi.ErrorResult{581 Message: err.Error(),582 }583 }584 newState, err := pm.ReadSinglePluginStateFromDisk(req.LocalName)585586 if err != nil {587 pm.finishWorkOnPlugin(req.LocalName, "error", "error re-reading plugin contents:"+err.Error())588 } else {589 pm.stateLock.Lock()590 pm.state[req.LocalName] = newState591 pm.loadPlugin(newState)592 pm.stateLock.Unlock()593594 pm.finishWorkOnPlugin(req.LocalName, "success", "updates applied")595 }596 responseCh <- jsonapi.SuccessResult{}597}598599func (pm *pluginManager) ApplyUpdates(localName string) error {600 repo, err := git.PlainOpen(filepath.Join(pm.CheckoutPath, localName))601 if err != nil {602 return err603 }604605 // determine current HEAD state606 head, err := repo.Head()607 if err != nil {608 return err609 }610 if !head.Name().IsBranch() {611 return errors.New(fmt.Sprintf("Module definition %s is not on a branch.", localName))612 }613 // check remote tracking branch614 ref, err := repo.Reference(plumbing.NewRemoteReferenceName(PluginManagerRemoteName, head.Name().Short()), true)615 if err != nil {616 return errors.New(fmt.Sprintf("error resolving ref: %v\n", err))617 }618 if ref.Hash() == head.Hash() {619 return errors.New(fmt.Sprintf("Module definition %s is already up-to-date.", localName))620 }621 wt, err := repo.Worktree()622 if err != nil {623 return err624 }625626 err = wt.Reset(&git.ResetOptions{627 Commit: ref.Hash(),628 Mode: git.HardReset,629 })630631 if err != nil {632 return err633 }634 return nil635}636637// notifyStateObservers sends a copy of the current state638// to each observer. The caller of this function has to hold the639// stateLock.640func (pm *pluginManager) notifyStateObservers() {641 pluginStateList := make([]PluginState, 0, len(pm.state))642 names := make([]string, 0, len(pm.state))643 for name := range pm.state {644 names = append(names, name)645 }646 sort.Strings(names)647 for _, name := range names {648 pluginStateList = append(pluginStateList, *pm.state[name])649 }650 for sub, _ := range pm.stateSubscriptions {651 select {652 case sub <- pluginStateList:653 case <-time.After(200 * time.Millisecond):654 fmt.Printf("PluginManager: notifyStateObservers(): failed to send state to subscriber\n")655 }656657 }658}659660// InstallModuleDefinition installs a module definition.661func (pm *pluginManager) InstallModuleDefinition(localName string, repoURL string) error {662 clonePath := filepath.Join(pm.CheckoutPath, localName)663 _, err := os.Stat(clonePath)664 if err == nil {665 return errors.New("module definition already installed, folder exists: " + clonePath)666 }667 _, err = git.PlainClone(clonePath, false, &git.CloneOptions{668 URL: repoURL,669 SingleBranch: false,670 RemoteName: PluginManagerRemoteName,671 })672 if err != nil {673 return err674 }675676 pluginState, err := pm.ReadSinglePluginStateFromDisk(localName)677 if err != nil {678 return errors.New("InstallModuleDefinition(): failed to read state after clone: " + err.Error())679 }680681 pm.stateLock.Lock()682 pm.state[localName] = pluginState683 pm.loadPlugin(pluginState)684 pm.notifyStateObservers()685 pm.stateLock.Unlock()686687 return nil688}689690type DcsLuaIndexEntry struct {691 PluginDir string `json:"pluginDir"`692 LuaFile string `json:"luaFile"`693}694695// updateDcsLuaIndex writes a list of all installed plugins696// to CheckoutPath\dcs-lua-index.json697// the caller has to hold the stateLock.698func (pm *pluginManager) updateDcsLuaIndex() {699 if pm.initialPluginLoadInProgress {700 return701 }702703 indexFilename := filepath.Join(pm.CheckoutPath, "dcs-lua-index.json")704 index := make([]DcsLuaIndexEntry, 0)705706 for _, pluginState := range pm.state {707 if pluginState.ModuleDefinitionName != "" {708 index = append(index, DcsLuaIndexEntry{709 PluginDir: filepath.Join(pm.CheckoutPath, pluginState.LocalName) + string(os.PathSeparator),710 LuaFile: filepath.Join(pm.CheckoutPath, pluginState.LocalName, pluginState.ModuleDefinitionName+".lua"),711 })712 }713 }714715 file, _ := os.Create(indexFilename)716 enc := json.NewEncoder(file)717 enc.SetEscapeHTML(false)718 enc.SetIndent("", " ")719 enc.Encode(index)720 file.Close()721722} ...

Full Screen

Full Screen

smtp.go

Source:smtp.go Github

copy

Full Screen

1package smtp2import (3 "context"4 "crypto/rand"5 "crypto/tls"6 "encoding/hex"7 "fmt"8 "net"9 gosmtp "net/smtp"10 "net/url"11 "strconv"12 "time"13 "github.com/getfider/fider/app/models/cmd"14 "github.com/getfider/fider/app/models/dto"15 "github.com/getfider/fider/app/pkg/bus"16 "github.com/getfider/fider/app/pkg/env"17 "github.com/getfider/fider/app/pkg/errors"18 "github.com/getfider/fider/app/pkg/log"19 "github.com/getfider/fider/app/pkg/web"20 "github.com/getfider/fider/app/services/email"21)22func init() {23 bus.Register(Service{})24}25type Service struct{}26func (s Service) Name() string {27 return "SMTP"28}29func (s Service) Category() string {30 return "email"31}32func (s Service) Enabled() bool {33 return env.Config.Email.Mailgun.APIKey == ""34}35func (s Service) Init() {36 bus.AddListener(sendMail)37}38func sendMail(ctx context.Context, c *cmd.SendMail) {39 if c.Props == nil {40 c.Props = dto.Props{}41 }42 for _, to := range c.To {43 if to.Address == "" {44 return45 }46 u, err := url.Parse(web.BaseURL(ctx))47 localname := "localhost"48 if err == nil {49 localname = u.Hostname()50 }51 if !email.CanSendTo(to.Address) {52 log.Warnf(ctx, "Skipping email to '@{Name} <@{Address}>'.", dto.Props{53 "Name": to.Name,54 "Address": to.Address,55 })56 return57 }58 log.Debugf(ctx, "Sending email to @{Address} with template @{TemplateName} and params @{Props}.", dto.Props{59 "Address": to.Address,60 "TemplateName": c.TemplateName,61 "Props": to.Props,62 })63 message := email.RenderMessage(c.TemplateName, c.Props.Merge(to.Props))64 b := builder{}65 b.Set("From", dto.NewRecipient(c.From, email.NoReply, dto.Props{}).String())66 b.Set("Reply-To", email.NoReply)67 b.Set("To", to.String())68 b.Set("Subject", message.Subject)69 b.Set("MIME-version", "1.0")70 b.Set("Content-Type", "text/html; charset=\"UTF-8\"")71 b.Set("Date", time.Now().Format(time.RFC1123Z))72 b.Set("Message-ID", generateMessageID(localname))73 b.Body(message.Body)74 smtpConfig := env.Config.Email.SMTP75 servername := fmt.Sprintf("%s:%s", smtpConfig.Host, smtpConfig.Port)76 auth := authenticate(smtpConfig.Username, smtpConfig.Password, smtpConfig.Host)77 err = Send(localname, servername, auth, email.NoReply, []string{to.Address}, b.Bytes())78 if err != nil {79 panic(errors.Wrap(err, "failed to send email with template %s", c.TemplateName))80 }81 log.Debug(ctx, "Email sent.")82 }83}84var Send = func(localName, serverAddress string, a gosmtp.Auth, from string, to []string, msg []byte) error {85 host, _, _ := net.SplitHostPort(serverAddress)86 c, err := gosmtp.Dial(serverAddress)87 if err != nil {88 return err89 }90 defer c.Close()91 if err = c.Hello(localName); err != nil {92 return err93 }94 if ok, _ := c.Extension("STARTTLS"); ok {95 config := &tls.Config{ServerName: host}96 if err = c.StartTLS(config); err != nil {97 return err98 }99 }100 if a != nil {101 if ok, _ := c.Extension("AUTH"); !ok {102 return errors.New("smtp: server doesn't support AUTH")103 }104 if err = c.Auth(a); err != nil {105 return err106 }107 }108 if err = c.Mail(from); err != nil {109 return err110 }111 for _, addr := range to {112 if err = c.Rcpt(addr); err != nil {113 return err114 }115 }116 w, err := c.Data()117 if err != nil {118 return err119 }120 _, err = w.Write(msg)121 if err != nil {122 return err123 }124 err = w.Close()125 if err != nil {126 return err127 }128 return c.Quit()129}130func generateMessageID(localName string) string {131 timestamp := strconv.FormatInt(time.Now().UTC().UnixNano(), 10)132 buf := make([]byte, 16)133 _, err := rand.Read(buf)134 if err != nil {135 panic(err)136 }137 randStr := hex.EncodeToString(buf)138 messageID := fmt.Sprintf("<%s.%s@%s>", randStr, timestamp, localName)139 return messageID140}141func authenticate(username string, password string, host string) gosmtp.Auth {142 if username == "" && password == "" {143 return nil144 }145 return AgnosticAuth("", username, password, host)146}147type builder struct {148 content string149}150func (b *builder) Set(key, value string) {151 b.content += fmt.Sprintf("%s: %s\r\n", key, value)152}153func (b *builder) Body(body string) {154 b.content += "\r\n" + body155}156func (b *builder) Bytes() []byte {157 return []byte(b.content)158}...

Full Screen

Full Screen

main.go

Source:main.go Github

copy

Full Screen

1package main2import (3 "fmt"4 "html/template"5 "os"6 "os/exec"7 "sync"8 "time"9 "github.com/coreos/go-systemd/journal"10 "github.com/fsnotify/fsnotify"11)12func main() {13 paths := os.Args[1:]14 if len(paths) == 0 {15 fmt.Fprintln(os.Stderr, "expecting path(s) to scan")16 os.Exit(2)17 }18 if err := run(paths); err != nil {19 fmt.Fprintln(os.Stderr, "failed to start up: ", err)20 os.Exit(1)21 }22}23const (24 // ScanDelay is how long we wait for file access to be quiescent before25 // initiating a scan.26 ScanDelay = 2 * time.Second27)28// timers map filenames to callbacks that actually perform a scan. The idea is29// to wait for 2s of quiescence before initiating the scan, in case the file is30// in the process of being modified.31var timers struct {32 lock sync.Mutex33 t map[string]*time.Timer34}35// run is the primary runtime function36func run(paths []string) error {37 timers.t = make(map[string]*time.Timer)38 var err error39 if successTpl, err = template.New("success").Parse(successTplT); err != nil {40 return err41 }42 if errorTpl, err = template.New("error").Parse(errorTplT); err != nil {43 return err44 }45 watcher, err := fsnotify.NewWatcher()46 if err != nil {47 return err48 }49 for _, path := range paths {50 if err = watcher.Add(path); err != nil {51 return err52 }53 }54 go func() {55 if err := <-watcher.Errors; err != nil {56 fmt.Fprintln(os.Stderr, "fsnotify error: ", err)57 os.Exit(1)58 }59 }()60 for ev := range watcher.Events {61 localName := ev.Name // don't close over the loop var62 timers.lock.Lock()63 if tmr, already := timers.t[localName]; already {64 // cancel existing timer65 tmr.Stop()66 }67 // start new timer waiting for file access to be quiescent68 timers.t[localName] = time.AfterFunc(ScanDelay, func() {69 scan(localName)70 timers.lock.Lock()71 delete(timers.t, localName)72 timers.lock.Unlock()73 })74 timers.lock.Unlock()75 }76 return nil77}78// scan a file and report the result via dialog.79func scan(name string) {80 jvars := map[string]string{81 "CLAMSCAN_FNAME": name,82 }83 // fsnotify will trigger on removed files, symlinks, directories etc.84 // so filter out those cases85 st, err := os.Lstat(name)86 switch {87 case os.IsNotExist(err):88 journal.Send(fmt.Sprintf("not executing clamscan on %q "+89 "as it was removed", name), journal.PriDebug, jvars)90 return91 case !st.Mode().IsRegular():92 journal.Send(fmt.Sprintf("not executing clamscan on %q "+93 "as it is mode %v", name, st.Mode()),94 journal.PriDebug, jvars)95 return96 }97 jvars["CLAMSCAN_FILESIZE"] = fmt.Sprintf("%d", st.Size())98 journal.Send(fmt.Sprintf("executing clamscan on %q "+99 "(%d bytes)", name, st.Size()),100 journal.PriDebug, jvars)101 clam := exec.Command("clamdscan", name)102 clamOP, err := clam.CombinedOutput()103 status := "success"104 priority := journal.PriNotice105 if err != nil {106 status = err.Error()107 priority = journal.PriAlert108 }109 jvars["CLAMSCAN_STATUS"] = status110 jvars["CLAMSCAN_OUTPUT"] = string(clamOP)111 journal.Send(fmt.Sprintf("clamscan executed on %q with status: %s",112 name, status), priority, jvars)113 dialog(clamOP, err)114}...

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc, err := html.Parse(os.Stdin)4 if err != nil {5 fmt.Fprintf(os.Stderr, "findlinks1: %v6 os.Exit(1)7 }8 for _, link := range visit(nil, doc) {9 fmt.Println(link)10 }11}12func visit(links []string, n *html.Node) []string {13 if n.Type == html.ElementNode {14 links = append(links, n.Data)15 }16 for c := n.FirstChild; c != nil; c = c.NextSibling {17 links = visit(links, c)18 }19}20import (21func main() {22 doc, err := html.Parse(os.Stdin)23 if err != nil {24 fmt.Fprintf(os.Stderr, "findlinks1: %v25 os.Exit(1)26 }27 for _, link := range visit(nil, doc) {28 fmt.Println(link)29 }30}31func visit(links []string, n *html.Node) []string {32 if n.Type == html.ElementNode && n.Data == "a" {33 for _, a := range n.Attr {34 if a.Key == "href" {35 links = append(links, a.Val)36 }37 }38 }39 for c := n.FirstChild; c != nil; c = c.NextSibling {40 links = visit(links, c)41 }42}43import (

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc, err := html.Parse(os.Stdin)4 if err != nil {5 fmt.Fprintf(os.Stderr, "findlinks1: %v6 os.Exit(1)7 }8 for _, link := range visit(nil, doc) {9 fmt.Println(link)10 }11}12func visit(links []string, n *html.Node) []string {13 if n.Type == html.ElementNode {14 links = append(links, n.Data)15 }16 for c := n.FirstChild; c != nil; c = c.NextSibling {17 links = visit(links, c)18 }19}

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc, err := html.Parse(os.Stdin)4 if err != nil {5 fmt.Fprintf(os.Stderr, "findlinks1: %v6 os.Exit(1)7 }8 for _, link := range visit(nil, doc) {9 fmt.Println(link)10 }11}12func visit(links []string, n *html.Node) []string {13 if n.Type == html.ElementNode {14 links = append(links, n.Data)15 }16 for c := n.FirstChild; c != nil; c = c.NextSibling {17 links = visit(links, c)18 }19}

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc, err := html.Parse(strings.NewReader("<html>"))4 if err != nil {5 fmt.Println(err)6 }7 fmt.Println(doc.Data)8}9import (10func main() {11 doc, err := html.Parse(strings.NewReader("<html id='id'>"))12 if err != nil {13 fmt.Println(err)14 }15 fmt.Println(doc.Attr[0].Key, doc.Attr[0].Val)16}17import (18func main() {19 doc, err := html.Parse(strings.NewReader("<html><body><p>hello</p></body></html>"))20 if err != nil {21 fmt.Println(err)22 }23 fmt.Println(node.Data)24}25import (26func main() {27 doc, err := html.Parse(strings.NewReader("<html><body><p>hello</p></body></html>"))28 if err != nil {29 fmt.Println(err)30 }31 fmt.Println(node.Data)32}33import (34func main() {35 doc, err := html.Parse(strings.NewReader("<html><body><p>hello</p></body></html>"))36 if err != nil {37 fmt.Println(err)38 }39 fmt.Println(node.Data)40}41import (

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc, err := html.Parse(strings.NewReader("<html><head><title>My Title</title></head><body><h1>My Title</h1></body></html>"))4 if err != nil {5 fmt.Println(err)6 }7 fmt.Println(doc.FirstChild.FirstChild.Data)8}9Recommended Posts: HTML | DOM - getElementsByTagName()10HTML | DOM - getAttribute()11HTML | DOM - getAttributeNode()12HTML | DOM - getAttributeNodeNS()13HTML | DOM - getAttributeNS()14HTML | DOM - getElementsByClassName()15HTML | DOM - getElementsByTagNameNS()16HTML | DOM - getElementsByTagName()17HTML | DOM - hasAttribute()18HTML | DOM - hasAttributeNS()19HTML | DOM - hasAttributes()20HTML | DOM - hasChildNodes()21HTML | DOM - insertBefore()22HTML | DOM - isDefaultNamespace()23HTML | DOM - isEqualNode()24HTML | DOM - isSameNode()25HTML | DOM - isSupported()26HTML | DOM - normalize()27HTML | DOM - removeAttribute()28HTML | DOM - removeAttributeNode()29HTML | DOM - removeAttributeNS()30HTML | DOM - removeChild()31HTML | DOM - replaceChild()32HTML | DOM - setAttribute()33HTML | DOM - setAttributeNode()34HTML | DOM - setAttributeNodeNS()35HTML | DOM - setAttributeNS()36HTML | DOM - setNodeValue()37HTML | DOM - setPrefix()38HTML | DOM - setUserData()39HTML | DOM - setXmlVersion()40HTML | DOM - splitText()41HTML | DOM - supports()42HTML | DOM - swapNode()43HTML | DOM - toLowerCase()44HTML | DOM - toUpperCase()45HTML | DOM - toString()46HTML | DOM - toXmlString()47HTML | DOM - transformNode()48HTML | DOM - transformNodeToObject()49HTML | DOM - uniqueID()50HTML | DOM - unselectable()51HTML | DOM - updateSettings()52HTML | DOM - validate()53HTML | DOM - xml()54HTML | DOM - xmlEncoding()55HTML | DOM - xmlStandalone()56HTML | DOM - xmlVersion()57HTML | DOM - doctype()58HTML | DOM - documentElement()59HTML | DOM - documentMode()60HTML | DOM - documentURI()61HTML | DOM - documentURIObject()

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 doc, err := html.Parse(strings.NewReader("<html><head><title>My Title</title></head></html>"))4 if err != nil {5 fmt.Println(err)6 }7 fmt.Println(doc.FirstChild.Data)8}

Full Screen

Full Screen

LocalName

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 if f, err = os.Open("test.html"); err != nil {4 fmt.Println(err)5 }6 defer f.Close()7 doc, err := html.Parse(f)8 if err != nil {9 fmt.Println(err)10 }11 var f1 func(*html.Node)12 f1 = func(n *html.Node) {13 if n.Type == html.ElementNode {14 fmt.Println(n.Data)15 }16 for c := n.FirstChild; c != nil; c = c.NextSibling {17 f1(c)18 }19 }20 f1(doc)21}

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run K6 automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful