Function TestBulkSMS_Excel

tests/integration_test.go:472–564

(t *testing.T)

}

func TestBulkSMS_Excel(t *testing.T) {
	ctx := context.Background()
	phone := setupPhone(ctx, t, 60)

	contact1 := randomPhoneNumber()
	contact2 := randomPhoneNumber()

	// Build Excel file with 2 messages
	f := excelize.NewFile()
	sheet := f.GetSheetName(0)
	f.SetCellValue(sheet, "A1", "FromPhoneNumber")
	f.SetCellValue(sheet, "B1", "ToPhoneNumber")
	f.SetCellValue(sheet, "C1", "Content")
	f.SetCellValue(sheet, "D1", "SendTime(optional)")

	f.SetCellValue(sheet, "A2", phone.PhoneNumber)
	f.SetCellValue(sheet, "B2", contact1)
	f.SetCellValue(sheet, "C2", "Excel bulk test message 1")
	f.SetCellValue(sheet, "D2", "")

	f.SetCellValue(sheet, "A3", phone.PhoneNumber)
	f.SetCellValue(sheet, "B3", contact2)
	f.SetCellValue(sheet, "C3", "Excel bulk test message 2")
	f.SetCellValue(sheet, "D3", "")

	var excelBuf bytes.Buffer
	require.NoError(t, f.Write(&excelBuf))

	// Upload Excel
	statusCode, respBody := uploadBulkFile(ctx, t, "test.xlsx", excelBuf.Bytes())
	require.Equal(t, http.StatusAccepted, statusCode, "upload failed: %s", string(respBody))
	t.Logf("upload response: %s", string(respBody))

	var uploadResp struct {
		Message string `json:"message"`
	}
	require.NoError(t, json.Unmarshal(respBody, &uploadResp))
	assert.Contains(t, uploadResp.Message, "2 out of 2")

	// Wait for messages to be persisted
	time.Sleep(2 * time.Second)

	// Search for bulk messages by owner and each contact
	messages1 := searchMessages(ctx, t, contact1, phone.PhoneNumber)
	messages2 := searchMessages(ctx, t, contact2, phone.PhoneNumber)
	messages := append(messages1, messages2...)
	require.GreaterOrEqual(t, len(messages), 2, "expected at least 2 messages for phone %s", phone.PhoneNumber)

	// Find messages with bulk- request_id prefix
	var bulkMessages []httpsms.Message
	var requestID string
	for i := range messages {
		if messages[i].RequestID != nil && strings.HasPrefix(*messages[i].RequestID, "bulk-") {
			bulkMessages = append(bulkMessages, messages[i])
			requestID = *messages[i].RequestID
		}
	}
	require.Len(t, bulkMessages, 2, "expected 2 messages with bulk- request_id")