import os
import disruptive as dt  # pip install disruptive
​
# Environment variables for authentication credentials.
KEY_ID = os.environ.get('DT_SERVICE_ACCOUNT_KEY_ID')
SECRET = os.environ.get('DT_SERVICE_ACCOUNT_SECRET')
EMAIL = os.environ.get('DT_SERVICE_ACCOUNT_EMAIL')
​
if __name__ == '__main__':
    # Authenticate using Service Account credentials.
    dt.default_auth = dt.Auth.service_account(KEY_ID, SECRET, EMAIL)
​
    # Make paginated requests for all available projects.
    projects = dt.Project.list_projects()
​
    # Print display name of all fetched projects.
    for i, project in enumerate(projects):
        print('{}. {}'.format(i, project.display_name))

const axios = require('axios').default // npm install [email protected]
​
// Environment variables for authentication and target.
const serviceAccountKeyID  = process.env.DT_SERVICE_ACCOUNT_KEY_ID
const serviceAccountSecret = process.env.DT_SERVICE_ACCOUNT_SECRET
​
baseUrl = 'https://api.d21s.com/v2'
​
async function getProjectsAutoPaginated() {
    // Initialize empty output list.
    let results = []
​
    // Create a parameters dictionary that contains an empty page token.
    let params = {'pageToken': ''}
​
    // Loop until all pages have been fetched.
    console.log('Paging...')
    while (true) {
        // Send GET request for projects.
        projects = await axios({
            method: 'GET',
            url: baseUrl+'/projects',
            auth: {
                username: serviceAccountKeyID,
                password: serviceAccountSecret,
            },
            params: params,
        })
​
        // Concatenate response contents to output list.
        results.push(...projects.data['projects'])
        let projectsInPage = projects.data['projects'].length
        console.log(`- Got ${projectsInPage} projects in page.`)
​
        // Update parameters with next page token.
        if (projects.data.nextPageToken.length > 0) {
            params.pageToken = projects.data.nextPageToken
        } else {
            break
        }
    }
​
    return results
}
​
async function main () {
    // Make paginated requests for all available projects.
    let projects = await getProjectsAutoPaginated()
​
    // Print display name of all fetched projects.
    for (i = 0; i < projects.length; i++) {
        console.log(`${i}. ${projects[i]['displayName']}`)
    }
}
​
main().catch((err) => {console.log(err)});

package main
​
import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os"
	"time"
)
​
const (
	baseURL = "https://api.d21s.com/v2"
)
​
// Environment variables for authentication and target.
var keyID = os.Getenv("DT_SERVICE_ACCOUNT_KEY_ID")
var secret = os.Getenv("DT_SERVICE_ACCOUNT_SECRET")
​
// Struct that represents a project fetched from the API.
type Project struct {
	Name                    string `json:"name"`
	DisplayName             string `json:"displayName"`
	Inventory               bool   `json:"inventory"`
	Organization            string `json:"organization"`
	OrganizationDisplayName string `json:"organizationDisplayName"`
	Sensorcount             int    `json:"sensorCount"`
	CloudConnectorCount     int    `json:"cloudConnectorCount"`
}
​
func getRequest(endpointURL string, pageToken string) ([]byte, error) {
	// Create a custom http Client with timeout.
	client := &http.Client{Timeout: time.Second * 3}
​
	// Create the request object with method, URL, but no optional body.
	req, err := http.NewRequest("GET", endpointURL, nil)
	if err != nil {
		return nil, err
	}
​
	// Add request parameters.
	q := req.URL.Query()
	q.Add("pageToken", pageToken)
	req.URL.RawQuery = q.Encode()
​
	// Set the request Authorization header to use HTTP Basic Authentication.
	req.SetBasicAuth(keyID, secret)
​
	// Send an HTTP request and return an HTTP response.
	response, err := client.Do(req)
	if err != nil {
		return nil, err
	}
	defer response.Body.Close()
​
	return ioutil.ReadAll(response.Body)
}
​
func getProjectsAutoPaginated() ([]Project, error) {
	// Initialize empty output slice.
	var projects []Project
​
	// Define page structure.
	type ProjectsPage struct {
		Projects      []Project `json:"projects"`
		NextPageToken string    `json:"nextPageToken"`
	}
​
	// Initialize empty page token.
	var pageToken = ""
​
	// Loop until all pages have been fetched.
	fmt.Println("Paging...")
	for {
		// Send GET request to the endpoint and get bytes back.
		pageBytes, err := getRequest(baseURL+"/projects", pageToken)
		if err != nil {
			return nil, err
		}
​
		// Decode pageBytes into an expected page structure.
		var page ProjectsPage
		if err := json.Unmarshal(pageBytes, &page); err != nil {
			return nil, err
		}
​
		// Concatenate page projects slice to result slice.
		projects = append(projects, page.Projects...)
		fmt.Printf("- Got %d projects in page.\n", len(page.Projects))
​
		// Update pageToken global variable.
		if len(page.NextPageToken) > 0 {
			pageToken = page.NextPageToken
		} else {
			break
		}
	}
​
	return projects, nil
}
​
func main() {
	// Make paginated requests for all available projects.
	projects, err := getProjectsAutoPaginated()
	if err != nil {
		log.Fatal(err)
	}
​
	// Print display name of all fetched projects.
	for i, project := range projects {
		fmt.Printf("%d. %s\n", i, project.DisplayName)
	}
}