Skip to content

Commit 581eef6

Browse files
committed
not serving proxied sites to ui
1 parent 0197842 commit 581eef6

File tree

1 file changed

+0
-63
lines changed

1 file changed

+0
-63
lines changed
Lines changed: 0 additions & 63 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,16 @@
11
package proxiedsites
22

33
import (
4-
"encoding/json"
5-
"fmt"
64
"sync"
75

86
"github.com/getlantern/detour"
97
"github.com/getlantern/golog"
108
"github.com/getlantern/proxiedsites"
11-
12-
"github.com/getlantern/flashlight/config"
13-
"github.com/getlantern/flashlight/ui"
14-
)
15-
16-
const (
17-
messageType = `proxiedSites`
189
)
1910

2011
var (
2112
log = golog.LoggerFor("flashlight.proxiedsites")
2213

23-
service *ui.Service
2414
PACURL string
2515
startMutex sync.Mutex
2616
)
@@ -34,26 +24,6 @@ func Configure(cfg *proxiedsites.Config) {
3424
if delta != nil {
3525
updateDetour(delta)
3626
}
37-
if service == nil {
38-
// Initializing service.
39-
if err := start(); err != nil {
40-
log.Errorf("Unable to register service: %q", err)
41-
}
42-
} else if delta != nil {
43-
// Sending delta.
44-
message := ui.Envelope{
45-
EnvelopeType: ui.EnvelopeType{messageType},
46-
Message: delta,
47-
}
48-
b, err := json.Marshal(message)
49-
50-
if err != nil {
51-
log.Errorf("Unable to publish delta to UI: %v", err)
52-
} else {
53-
service.Out <- b
54-
}
55-
}
56-
5727
startMutex.Unlock()
5828
}
5929

@@ -75,36 +45,3 @@ func updateDetour(delta *proxiedsites.Delta) {
7545
detour.AddToWl(v+":443", true)
7646
}
7747
}
78-
79-
func start() (err error) {
80-
newMessage := func() interface{} {
81-
return &proxiedsites.Delta{}
82-
}
83-
84-
// Registering a websocket service.
85-
helloFn := func(write func(interface{}) error) error {
86-
return write(proxiedsites.ActiveDelta())
87-
}
88-
89-
if service, err = ui.Register(messageType, newMessage, helloFn); err != nil {
90-
return fmt.Errorf("Unable to register channel: %q", err)
91-
}
92-
93-
// Initializing reader.
94-
go read()
95-
96-
return nil
97-
}
98-
99-
func read() {
100-
for msg := range service.In {
101-
err := config.Update(func(updated *config.Config) error {
102-
log.Debugf("Applying update from UI")
103-
updated.ProxiedSites.Delta.Merge(msg.(*proxiedsites.Delta))
104-
return nil
105-
})
106-
if err != nil {
107-
log.Debugf("Error applying update from UI: %v", err)
108-
}
109-
}
110-
}

0 commit comments

Comments
 (0)