@@ -114,10 +114,10 @@ func setupTestHelper(enterprise bool, updateConfig func(*model.Config)) *TestHel
114
114
}
115
115
116
116
th .App .UpdateConfig (func (cfg * model.Config ) { * cfg .ServiceSettings .ListenAddress = prevListenAddress })
117
- Init (th .Server , th .Server .AppOptions , th .App .Srv .Router )
118
- web .New (th .Server , th .Server .AppOptions , th .App .Srv .Router )
119
- wsapi .Init (th .App , th .App .Srv .WebSocketRouter )
120
- th .App .Srv .Store .MarkSystemRanUnitTests ()
117
+ Init (th .Server , th .Server .AppOptions , th .App .Srv () .Router )
118
+ web .New (th .Server , th .Server .AppOptions , th .App .Srv () .Router )
119
+ wsapi .Init (th .App , th .App .Srv () .WebSocketRouter )
120
+ th .App .Srv () .Store .MarkSystemRanUnitTests ()
121
121
th .App .DoAppMigrations ()
122
122
123
123
th .App .UpdateConfig (func (cfg * model.Config ) { * cfg .TeamSettings .EnableOpenServer = true })
@@ -227,7 +227,7 @@ func (me *TestHelper) InitBasic() *TestHelper {
227
227
228
228
func (me * TestHelper ) waitForConnectivity () {
229
229
for i := 0 ; i < 1000 ; i ++ {
230
- conn , err := net .Dial ("tcp" , fmt .Sprintf ("localhost:%v" , me .App .Srv .ListenAddr .Port ))
230
+ conn , err := net .Dial ("tcp" , fmt .Sprintf ("localhost:%v" , me .App .Srv () .ListenAddr .Port ))
231
231
if err == nil {
232
232
conn .Close ()
233
233
return
@@ -238,19 +238,19 @@ func (me *TestHelper) waitForConnectivity() {
238
238
}
239
239
240
240
func (me * TestHelper ) CreateClient () * model.Client4 {
241
- return model .NewAPIv4Client (fmt .Sprintf ("http://localhost:%v" , me .App .Srv .ListenAddr .Port ))
241
+ return model .NewAPIv4Client (fmt .Sprintf ("http://localhost:%v" , me .App .Srv () .ListenAddr .Port ))
242
242
}
243
243
244
244
func (me * TestHelper ) CreateWebSocketClient () (* model.WebSocketClient , * model.AppError ) {
245
- return model .NewWebSocketClient4 (fmt .Sprintf ("ws://localhost:%v" , me .App .Srv .ListenAddr .Port ), me .Client .AuthToken )
245
+ return model .NewWebSocketClient4 (fmt .Sprintf ("ws://localhost:%v" , me .App .Srv () .ListenAddr .Port ), me .Client .AuthToken )
246
246
}
247
247
248
248
func (me * TestHelper ) CreateWebSocketSystemAdminClient () (* model.WebSocketClient , * model.AppError ) {
249
- return model .NewWebSocketClient4 (fmt .Sprintf ("ws://localhost:%v" , me .App .Srv .ListenAddr .Port ), me .SystemAdminClient .AuthToken )
249
+ return model .NewWebSocketClient4 (fmt .Sprintf ("ws://localhost:%v" , me .App .Srv () .ListenAddr .Port ), me .SystemAdminClient .AuthToken )
250
250
}
251
251
252
252
func (me * TestHelper ) CreateWebSocketClientWithClient (client * model.Client4 ) (* model.WebSocketClient , * model.AppError ) {
253
- return model .NewWebSocketClient4 (fmt .Sprintf ("ws://localhost:%v" , me .App .Srv .ListenAddr .Port ), client .AuthToken )
253
+ return model .NewWebSocketClient4 (fmt .Sprintf ("ws://localhost:%v" , me .App .Srv () .ListenAddr .Port ), client .AuthToken )
254
254
}
255
255
256
256
func (me * TestHelper ) CreateBotWithSystemAdminClient () * model.Bot {
@@ -318,7 +318,7 @@ func (me *TestHelper) CreateUserWithClient(client *model.Client4) *model.User {
318
318
}
319
319
320
320
ruser .Password = "Pa$$word11"
321
- _ , err := me .App .Srv .Store .User ().VerifyEmail (ruser .Id , ruser .Email )
321
+ _ , err := me .App .Srv () .Store .User ().VerifyEmail (ruser .Id , ruser .Email )
322
322
if err != nil {
323
323
return nil
324
324
}
@@ -420,7 +420,7 @@ func (me *TestHelper) CreateMessagePostWithClient(client *model.Client4, channel
420
420
}
421
421
422
422
func (me * TestHelper ) CreateMessagePostNoClient (channel * model.Channel , message string , createAtTime int64 ) * model.Post {
423
- post , err := me .App .Srv .Store .Post ().Save (& model.Post {
423
+ post , err := me .App .Srv () .Store .Post ().Save (& model.Post {
424
424
UserId : me .BasicUser .Id ,
425
425
ChannelId : channel .Id ,
426
426
Message : message ,
@@ -751,9 +751,9 @@ func (me *TestHelper) cleanupTestFile(info *model.FileInfo) error {
751
751
func (me * TestHelper ) MakeUserChannelAdmin (user * model.User , channel * model.Channel ) {
752
752
utils .DisableDebugLogForTest ()
753
753
754
- if cm , err := me .App .Srv .Store .Channel ().GetMember (channel .Id , user .Id ); err == nil {
754
+ if cm , err := me .App .Srv () .Store .Channel ().GetMember (channel .Id , user .Id ); err == nil {
755
755
cm .SchemeAdmin = true
756
- if _ , err = me .App .Srv .Store .Channel ().UpdateMember (cm ); err != nil {
756
+ if _ , err = me .App .Srv () .Store .Channel ().UpdateMember (cm ); err != nil {
757
757
utils .EnableDebugLogForTest ()
758
758
panic (err )
759
759
}
@@ -768,9 +768,9 @@ func (me *TestHelper) MakeUserChannelAdmin(user *model.User, channel *model.Chan
768
768
func (me * TestHelper ) UpdateUserToTeamAdmin (user * model.User , team * model.Team ) {
769
769
utils .DisableDebugLogForTest ()
770
770
771
- if tm , err := me .App .Srv .Store .Team ().GetMember (team .Id , user .Id ); err == nil {
771
+ if tm , err := me .App .Srv () .Store .Team ().GetMember (team .Id , user .Id ); err == nil {
772
772
tm .SchemeAdmin = true
773
- if _ , err = me .App .Srv .Store .Team ().UpdateMember (tm ); err != nil {
773
+ if _ , err = me .App .Srv () .Store .Team ().UpdateMember (tm ); err != nil {
774
774
utils .EnableDebugLogForTest ()
775
775
panic (err )
776
776
}
@@ -788,9 +788,9 @@ func (me *TestHelper) UpdateUserToTeamAdmin(user *model.User, team *model.Team)
788
788
func (me * TestHelper ) UpdateUserToNonTeamAdmin (user * model.User , team * model.Team ) {
789
789
utils .DisableDebugLogForTest ()
790
790
791
- if tm , err := me .App .Srv .Store .Team ().GetMember (team .Id , user .Id ); err == nil {
791
+ if tm , err := me .App .Srv () .Store .Team ().GetMember (team .Id , user .Id ); err == nil {
792
792
tm .SchemeAdmin = false
793
- if _ , err = me .App .Srv .Store .Team ().UpdateMember (tm ); err != nil {
793
+ if _ , err = me .App .Srv () .Store .Team ().UpdateMember (tm ); err != nil {
794
794
utils .EnableDebugLogForTest ()
795
795
panic (err )
796
796
}
0 commit comments