pkg/testsuite/mqtt_test.go:443: 443-483 lines are duplicate of `pkg/testsuite/mqtt_test.go:575-615` (dupl)
		func() *test {
			accountOutput := tpkg.RandOutput(iotago.OutputAccount).(*iotago.AccountOutput)
			testTx := ts.NewTestTransaction(true, tpkg.WithOutputs(iotago.Outputs[iotago.TxEssenceOutput]{
				accountOutput,
			}))

			return &test{
				name: "ok - TopicAccountOutputs",
				topics: []*testTopic{
					{
						topic:           mqtt.GetTopicAccountOutputs(accountOutput.AccountID, ts.API().ProtocolParameters().Bech32HRP()),
						isPollingTarget: false,
						isEventTarget:   true,
					},
				},
				topicsIgnore: []string{
					mqtt.GetTopicTransactionsIncludedBlock(testTx.TransactionID),
					mqtt.GetTopicOutput(testTx.ConsumedOutputID),
					mqtt.GetTopicOutput(testTx.OutputID),
					mqtt.GetTopicOutputsByUnlockConditionAndAddress(mqtt.UnlockConditionAny, testTx.OwnerAddress, ts.API().ProtocolParameters().Bech32HRP()),
					mqtt.GetTopicOutputsByUnlockConditionAndAddress(mqtt.UnlockConditionAddress, testTx.OwnerAddress, ts.API().ProtocolParameters().Bech32HRP()),
				},
				jsonTarget: lo.PanicOnErr(ts.API().JSONEncode(testTx.OutputWithMetadataResponse)),
				rawTarget:  lo.PanicOnErr(ts.API().Encode(testTx.OutputWithMetadataResponse)),
				postSubscribeFunc: func() {
					ts.ReceiveAcceptedTransaction(&nodebridge.AcceptedTransaction{
						API:           ts.API(),
						Slot:          testTx.BlockID.Slot(),
						TransactionID: testTx.TransactionID,
						// the consumed input
						Consumed: []*nodebridge.Output{
							ts.NewSpentNodeBridgeOutputFromTransaction(tpkg.RandBlockID(), testTx.ConsumedOutputCreationTransaction, testTx.BlockID.Slot(), testTx.TransactionID),
						},
						// the created output
						Created: []*nodebridge.Output{
							ts.NewNodeBridgeOutputFromOutputWithMetadata(testTx.OutputWithMetadataResponse),
						},
					})
				},
			}
		}(),

pkg/testsuite/mqtt_test.go:575: 575-615 lines are duplicate of `pkg/testsuite/mqtt_test.go:443-483` (dupl)
		func() *test {
			nftOutput := tpkg.RandOutput(iotago.OutputNFT).(*iotago.NFTOutput)
			testTx := ts.NewTestTransaction(true, tpkg.WithOutputs(iotago.Outputs[iotago.TxEssenceOutput]{
				nftOutput,
			}))

			return &test{
				name: "ok - TopicNFTOutputs",
				topics: []*testTopic{
					{
						topic:           mqtt.GetTopicNFTOutputs(nftOutput.NFTID, ts.API().ProtocolParameters().Bech32HRP()),
						isPollingTarget: false,
						isEventTarget:   true,
					},
				},
				topicsIgnore: []string{
					mqtt.GetTopicTransactionsIncludedBlock(testTx.TransactionID),
					mqtt.GetTopicOutput(testTx.ConsumedOutputID),
					mqtt.GetTopicOutput(testTx.OutputID),
					mqtt.GetTopicOutputsByUnlockConditionAndAddress(mqtt.UnlockConditionAny, testTx.OwnerAddress, ts.API().ProtocolParameters().Bech32HRP()),
					mqtt.GetTopicOutputsByUnlockConditionAndAddress(mqtt.UnlockConditionAddress, testTx.OwnerAddress, ts.API().ProtocolParameters().Bech32HRP()),
				},
				jsonTarget: lo.PanicOnErr(ts.API().JSONEncode(testTx.OutputWithMetadataResponse)),
				rawTarget:  lo.PanicOnErr(ts.API().Encode(testTx.OutputWithMetadataResponse)),
				postSubscribeFunc: func() {
					ts.ReceiveAcceptedTransaction(&nodebridge.AcceptedTransaction{
						API:           ts.API(),
						Slot:          testTx.BlockID.Slot(),
						TransactionID: testTx.TransactionID,
						// the consumed input
						Consumed: []*nodebridge.Output{
							ts.NewSpentNodeBridgeOutputFromTransaction(tpkg.RandBlockID(), testTx.ConsumedOutputCreationTransaction, testTx.BlockID.Slot(), testTx.TransactionID),
						},
						// the created output
						Created: []*nodebridge.Output{
							ts.NewNodeBridgeOutputFromOutputWithMetadata(testTx.OutputWithMetadataResponse),
						},
					})
				},
			}
		}(),

pkg/testsuite/mqtt_test.go:892:35: string `/raw` has 6 occurrences, make it a constant (goconst)
				topicNameRaw := topic.topic + "/raw"
				                              ^

pkg/testsuite/broker_mock.go:79:2: commentFormatting: put a space between `//` and comment text (gocritic)
	//if m.sendCallback != nil {
	^

pkg/testsuite/mqtt_test.go:7: File is not `goimports`-ed with -local github.com/iotaledger (goimports)

pkg/testsuite/mqtt_test.go:887:23: Using the variable on range scope `test` in function literal (scopelint)
					require.Equal(t, test.jsonTarget, payloadBytes, "JSON payload mismatch")
					                 ^

pkg/testsuite/mqtt_test.go:905:23: Using the variable on range scope `test` in function literal (scopelint)
					require.Equal(t, test.rawTarget, payloadBytes, "raw payload mismatch")
					                 ^

pkg/testsuite/mqtt_test.go:913:34: Using the variable on range scope `test` in function literal (scopelint)
				for _, ignoredTopic := range test.topicsIgnore {
				                             ^

pkg/testsuite/mqtt_test.go:926:33: Using the variable on range scope `test` in function literal (scopelint)
			collectedTopics := lo.Reduce(test.topics, func(collectedTopics map[string]int, topic *testTopic) map[string]int {
			                             ^

pkg/testsuite/mqtt_test.go:940:7: Using the variable on range scope `test` in function literal (scopelint)
			if test.preSubscribeFunc != nil {
			   ^

pkg/testsuite/mqtt_test.go:941:5: Using the variable on range scope `test` in function literal (scopelint)
				test.preSubscribeFunc()
				^

pkg/testsuite/mqtt_test.go:945:30: Using the variable on range scope `test` in function literal (scopelint)
			for _, testTopic := range test.topics {
			                          ^

pkg/testsuite/mqtt_test.go:956:7: Using the variable on range scope `test` in function literal (scopelint)
			if test.postSubscribeFunc != nil {
			   ^

pkg/testsuite/mqtt_test.go:957:5: Using the variable on range scope `test` in function literal (scopelint)
				test.postSubscribeFunc()
				^

pkg/testsuite/mqtt_test.go:964:30: Using the variable on range scope `test` in function literal (scopelint)
			for _, testTopic := range test.topics {
			                          ^

pkg/testsuite/nodebridge_mock.go:412:2: `ctx` is unused (structcheck)
	ctx          context.Context
	^

pkg/testsuite/nodebridge_mock.go:413:2: `cancel` is unused (structcheck)
	cancel       context.CancelFunc
	^

pkg/testsuite/nodebridge_mock.go:414:2: `receiverChan` is unused (structcheck)
	receiverChan chan *T
	^

pkg/testsuite/testsuite.go:224:2: missing cases in switch of type iotago.OutputType: iotago.OutputBasic, iotago.OutputAccount, iotago.OutputNFT, iotago.OutputDelegation (exhaustive)
	switch createdOutput.Type() {
	^

pkg/testsuite/testsuite.go:203:2: type assertion must be checked (forcetypeassert)
	transaction := &iotago.Transaction{
	^

pkg/testsuite/testsuite.go:234:2: type assertion must be checked (forcetypeassert)
	consumedOutput := tpkg.RandOutput(iotago.OutputBasic).(*iotago.BasicOutput)
	^

pkg/testsuite/mqtt_test.go:444:4: type assertion must be checked (forcetypeassert)
			accountOutput := tpkg.RandOutput(iotago.OutputAccount).(*iotago.AccountOutput)
			^

pkg/testsuite/mqtt_test.go:487:4: type assertion must be checked (forcetypeassert)
			anchorOutput := tpkg.RandOutput(iotago.OutputAnchor).(*iotago.AnchorOutput)
			^

pkg/testsuite/mqtt_test.go:532:4: type assertion must be checked (forcetypeassert)
			foundryOutput := tpkg.RandOutput(iotago.OutputFoundry).(*iotago.FoundryOutput)
			^

pkg/testsuite/mqtt_test.go:576:4: type assertion must be checked (forcetypeassert)
			nftOutput := tpkg.RandOutput(iotago.OutputNFT).(*iotago.NFTOutput)
			^